tokio-batch
An adaptor that chunks up elements and flushes them after a timeout or when the buffer is full.
Description
An adaptor that chunks up elements in a vector.
This adaptor will buffer up a list of items in the stream and pass on the vector used for buffering when a specified capacity has been reached or a predefined timeout was triggered.
Usage
Either as a standalone Stream Operator or directly as a combinator:
use future;
use stream;
use ;
use Duration;
use ChunksTimeoutStreamExt;
Note: This is using the futures-preview
crate.
Check this blog post about the futures-rs compability layer.
Credits
This was taken and adjusted from futures-util and moved into a separate crate for reusability.
Thanks to @arielb1, @alexcrichton, @spebern, and @wngr for their contributions!