futures-batch icon indicating copy to clipboard operation
futures-batch copied to clipboard

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.)

Results 2 futures-batch issues
Sort by recently updated
recently updated
newest added

`futures::stream::TryStreamExt` has a `try_chunks` method that batches `Ok` values and immediately propagates any `Err` values. I believe it would be very useful to have something like that in this library.

Creating a `Delay` is a relatively heavy operation which involves creating two mutexes and an `Arc`, so it makes sense to avoid calling `Delay::new` repeatedly. In this change I introduced...