mre / futures-batch
An adapter for futures, which chunks up elements and flushes them after a timeout — or when the buffer is full. (Formerly known as tokio-batch.)
☆76Updated 6 months ago
Related projects ⓘ
Alternatives and complementary repositories for futures-batch
- bencher is just a port of the libtest (unstable) benchmark runner to Rust stable releases. `cargo bench` on stable. "Not a better bencher…☆85Updated 2 years ago
- Heap-based async timers☆211Updated 5 months ago
- Async tracing capabilities for the log crate☆99Updated 3 years ago
- A leaky-bucket-as-a-meter rate-limiting implementation in Rust☆33Updated 4 years ago
- Rust Stream combinator, to limit the rate at which items are produced☆26Updated last year
- Retriever stores ordinary rust data types in a similar manner as a NoSQL database.☆48Updated last year
- How to run Hyper on async-std☆39Updated 2 years ago
- A fast, small, full-featured, no-std compatible oneshot channel☆61Updated 11 months ago
- Log call tree summaries after each request for rust programs instrumented with `tracing`.☆43Updated 2 years ago
- Run closures in parallel☆109Updated last month
- A concurrent circuit breaker implemented with ring buffers☆118Updated 9 months ago
- Integer encoding for primitive integer types: Supports varint/varint+zigzag and fixed-length integer encoding and decoding, and provides …☆66Updated 3 months ago
- A futures abstraction that runs a set of futures which may complete in any order.☆89Updated 3 months ago
- Streamline updating a Tokio 0.1 application to Tokio 0.2.☆51Updated 3 years ago
- ☆44Updated 10 months ago
- Async filesystem primitives☆130Updated last month
- Rust serializer library☆85Updated 6 months ago
- A Rust library for generically joining iterables with a separator☆91Updated last year
- A token-based rate limiter based on the leaky bucket algorithm.☆93Updated 3 months ago
- An async NATS client library for the Rust programming language.☆82Updated 5 months ago
- Serde support for the humantime crate☆27Updated 9 months ago
- Message broker for the Actix actor framework☆37Updated 3 years ago
- Bounded MPMC channel abstraction on top of a ring buffer☆39Updated 3 months ago
- A map implementation that relies on fixed-size storage derived by a procedural macro☆42Updated 3 weeks ago
- A global executor built on top of async-executor and smol☆74Updated 5 months ago
- Test harness for declarative and procedural macros expansion via `cargo-expand`☆51Updated 4 months ago
- Serialization value trees☆43Updated 3 months ago
- Native TLS for futures and async-std☆70Updated 4 months ago
- Concurrent hash trie☆51Updated 4 years ago