rust-stream-ext-concurrent
Concurrent behavior extensions for any futures::stream::Stream
objects.
Detail
A native Rust futures infrastructure futures::stream::FuturesUnordered
is used to internally cache and enable concurrent processing of Stream
objects.
Supported extensions
then_concurrent
method extends everyStream
to add the desired functionality to use the concurrent execution capability ofFuturesUnordered