1 stable release
1.0.0 | Jan 11, 2024 |
---|
#1450 in Asynchronous
38 downloads per month
8KB
132 lines
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
Dependencies
~1–1.6MB
~33K SLoC