mikecaines / stream-throttleLinks
Rust Stream combinator, to limit the rate at which items are produced
☆28Updated 2 years ago
Alternatives and similar repositories for stream-throttle
Users that are interested in stream-throttle are comparing it to the libraries listed below
Sorting:
- An adapter for futures, which chunks up elements and flushes them after a timeout — or when the buffer is full. (Formerly known as tokio-…☆81Updated last month
- A map implementation that relies on fixed-size storage derived by a procedural macro☆53Updated 3 months ago
- Integer encoding for primitive integer types: Supports varint/varint+zigzag and fixed-length integer encoding and decoding, and provides …☆69Updated 2 months ago
- ☆41Updated 2 years ago
- Run closures in parallel☆115Updated 11 months ago
- Rust serializer library☆89Updated 3 months ago
- A fast, small, full-featured, no-std compatible oneshot channel☆61Updated 2 years ago
- Asynchronous byte buffers and pipes for concurrent I/O programming.☆102Updated last month
- Concurrent hash trie☆58Updated 5 years ago
- A futures abstraction that runs a set of futures which may complete in any order.☆92Updated 3 months ago
- Serializable trait objects for Rust.☆58Updated 9 months ago
- Serialization value trees☆48Updated last year
- Generate is a library for building iterators on the fly☆39Updated 4 years ago
- ☆48Updated last year
- ☆87Updated 2 months ago
- Utilities for encoding and decoding frames with async/await☆76Updated 4 years ago
- Retriever stores ordinary rust data types in a similar manner as a NoSQL database.☆47Updated 2 years ago
- ☆73Updated 4 years ago
- An updated version of linked-hash-map and friends☆139Updated 2 months ago
- Async filesystem primitives☆142Updated 2 months ago
- ☆109Updated last year
- Avrow is a pure Rust implementation of the avro specification https://avro.apache.org/docs/current/spec.html with Serde support.☆29Updated 3 years ago
- Async tracing capabilities for the log crate☆98Updated 5 years ago
- Streamline updating a Tokio 0.1 application to Tokio 0.2.☆52Updated 5 years ago
- Data parallelism library for async-std.☆96Updated last year
- Duplicate an async I/O handle☆41Updated 11 months ago
- Test harness for declarative and procedural macros expansion via `cargo-expand`☆67Updated 5 months ago
- ☆126Updated 3 years ago
- ☆61Updated 2 years ago
- Oneshot Rust channel working both in and between sync and async environments☆97Updated 10 months ago