Crate futures_batch
source ·Expand description
An adaptor that chunks up completed futures in a stream and flushes them after a timeout or when the buffer is full.
It is based on the Chunks
adaptor of futures-util, to which we added a timeout.
Usage
Either as a standalone stream operator or directly as a combinator:
use std::time::Duration;
use futures::{stream, StreamExt};
use futures_batch::ChunksTimeoutStreamExt;
#[tokio::main]
async fn main() {
let iter = vec![0, 1, 2, 3, 4, 5, 6, 7, 8, 9].into_iter();
let results = stream::iter(iter)
.chunks_timeout(5, Duration::new(10, 0))
.collect::<Vec<_>>();
assert_eq!(vec![vec![0, 1, 2, 3, 4], vec![5, 6, 7, 8, 9]], results.await);
}
The above code iterates over a stream and creates chunks of size 5 with a timeout of 10 seconds.
Structs
A Stream of chunks.
Traits
A Stream extension trait allowing you to call
chunks_timeout
on anything
which implements Stream
.