[−][src]Trait and_then_concurrent::TryStreamAndThenExt
Extension to futures_util::stream::TryStreamExt
Required methods
pub fn and_then_concurrent<Fut, F>(
self,
f: F
) -> AndThenConcurrent<Self, Fut, F> where
Self: Sized,
Fut: TryFuture<Error = Self::Error>,
F: FnMut(Self::Ok) -> Fut,
[src]
self,
f: F
) -> AndThenConcurrent<Self, Fut, F> where
Self: Sized,
Fut: TryFuture<Error = Self::Error>,
F: FnMut(Self::Ok) -> Fut,
Chain a computation when a stream value is ready, passing Ok
values to the closure f
.
This function is similar to futures_util::stream::TryStreamExt::and_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
.
See crate-level docs for an explanation and usage example.
Implementors
impl<S: TryStream> TryStreamAndThenExt for S
[src]
pub fn and_then_concurrent<Fut, F>(
self,
f: F
) -> AndThenConcurrent<Self, Fut, F> where
Self: Sized,
Fut: TryFuture<Error = Self::Error>,
F: FnMut(Self::Ok) -> Fut,
[src]
self,
f: F
) -> AndThenConcurrent<Self, Fut, F> where
Self: Sized,
Fut: TryFuture<Error = Self::Error>,
F: FnMut(Self::Ok) -> Fut,