Trait StreamThenConcurrentExt

pub trait StreamThenConcurrentExt: Stream {
    // Required method
    fn then_concurrent<Fut, F>(self, f: F) -> ThenConcurrent<Self, Fut, F>
       where Self: Sized,
             Fut: Future,
             F: FnMut(Self::Item) -> Fut;
}

Extension to futures::stream::Stream

Required Methods

fn then_concurrent<Fut, F>(self, f: F) -> ThenConcurrent<Self, Fut, F>

where Self: Sized, Fut: Future, F: FnMut(Self::Item) -> Fut,

Chain a computation when a stream value is ready, passing Ok values to the closure f.

This function is similar to futures::stream::StreamExt::then, but the stream is polled concurrently with the futures returned by f. An unbounded number of futures corresponding to past stream values is kept via FuturesUnordered.

Implementors

impl<S: Stream> StreamThenConcurrentExt for S