futures-batch
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...