Lib.rs

› Keywords #future-stream #concurrency #future #tokio-stream #events #tokio

#stream-ext

  1. spawn_groups

    Structured concurrency construct written in Rust, for Rustaceans

    v1.1.0 140 #concurrency #construct #rustaceans #task #structured #stream-ext #async-std

  2. ogre-stream-ext

    futures shortcuts with ergonomic extensions to unlock the full power of Streams in Rust

    v0.1.6 480 #reactive-programming #stream-ext #extension #stream

  3. roughage

    AsyncPipeline, a deadlock-free replacement for buffered streams

    v0.1.1 #async-pipeline #replace #deadlock #buffered #future #deadlock-free #stream-ext #tokio-time #concurrency #snooze

  4. resy

    Remote Sync change detection lib. Currently supporting AWS S3 but possibly open to more sources.

    v0.1.0 #amazon-s3 #change-detection #detect #source #aws #database #etag #tokio-stream #client-builder #stream-ext

  5. storeit

    Ergonomic repository facade over storeit_core with optional SQL builder and backend adapters

    v0.1.7 150 #repository #back-end #facade #adapter #mysql #sql-builder #stream-ext #query-ext

  6. stream_lib

    download differnt types of streams

    v0.5.2 4.9K #hls #stream-download #lib #events #chunked #stream-ext #async-write-ext

  7. crypto-auditing

    Client library for crypto-auditing project

    v0.3.0 #client #events #auditing #stream-ext #tokio #future-stream #cryptography

  8. stream-more

    Stream utilities for Rust

    v0.1.3 2.3K #stream #stream-ext

  9. futures-concurrency-dynamic

    A dynamic extension of the futures-concurrency

    v0.2.2 #future-concurrency #dynamic #stream-ext #extension #merge

  10. stream-ext

    An extension trait for Streams that provides a variety of convenient combinator functions

    v0.2.4 #rate-limiting #stream #rate-limiter

  11. crossword_generator

    generating crossword from provided words

    v0.0.2 #crossword #generator #word #async-runtime #direction #stream-ext #tokio-stream #crosswords

  12. stream-find

    Add a find and find_map methods to any stream

    v0.3.0 #return #find-map #methods #match #future-stream #stream-ext

  13. cmdwrap

    Command for run shell script

    v0.1.1 #shell #run-command #command-run #stream #script #stream-ext #pin-mut

    14. Try searching with DuckDuckGo.

  14. futures-stream-select-ext

    futures::stream::select Ext

    v0.1.3 #stream #future-stream #stream-ext #package

  15. tokio_x_codec

    tokio codec. auto impl tokio_util::codec::Encoder and tokio_util::codec::Decoder.

    v0.0.1-beta1 #tokio-codec #tokio-util #decoder #impl #decode #auto-impl #bytes-mut #stream-ext #buf-mut

  16. enstream

    Conversion from Future to Stream

    v0.3.0 #future-stream #convert #yielder #handler-fn #stream-ext

  17. tokio-into-sink

    convert a tokio::io::AsyncWrite into a futures::Sink for bytes

    v0.1.0 #async-write #tokio #future #sink #convert #stream-ext

  18. electrum_streaming_client

    Experimental but sane electrum client by @evanlinjin

    v0.4.0 200 #electrum #json-rpc #request #sans-io #notifications #blocking #stream-ext #streaming-protocol #evanlinjin

  19. modular-sys

    Native bindings to modular-rs

    v0.1.0 #native #dll #future #bindings #publish #native-bindings #stream-ext #tower #service-fn

  20. modular-native

    Native bindings to modular-rs

    v0.1.1 #native #modular #tokio #future #native-bindings #modular-rs #stream-ext #dll #service-fn #tower

  21. ndless-async

    Ndless-specific integration with async/await for the TI-Nspire

    v0.1.2 #async-task #ti-nspire #ndless #keypad #timeout #stream-ext #block-on

  22. select-next-any

    Alternative to futures::StreamExt::select_next_some that returns the None variant

    v0.1.0 270 #stream-ext #future #variant #next

  23. mirai-ws

    mirai-http-api rust interface, based on tungstenite

    v0.0.2 #tungstenite #interface #mirai-http-api #conn #protocols #qq #stream-ext

  24. modular-rs

    manage modules and events

    v0.1.0 #events #service #tokio #body #manage #stream-ext #dll #tower