Module then_concurrent

Source
Expand description

Highly inspired by and_then_concurrent

ThenConcurrent extension adds the then_concurrent method to any futures::stream::Stream object allowing a concurrent execution of futures over the stream items.

Structs§

ThenConcurrent
Stream for the [Stream::then_concurrent()] method.

Traits§

StreamThenConcurrentExt
Extension to futures::stream::Stream