rust-stream-ext-concurrent 1.0.0

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

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