#stream #extension #future #stream-processing #concurrency #object #behavior

rust-stream-ext-concurrent

Concurrent behavior extensions for any futures::stream::Stream objects

1 stable release

1.0.0 Jan 11, 2024

#1450 in Asynchronous

38 downloads per month

MIT license

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 every Stream to add the desired functionality to use the concurrent execution capability of FuturesUnordered

Dependencies

~1–1.6MB
~33K SLoC