Struct futures_util::stream::ForEachConcurrent
[−]
[src]
#[must_use = "streams do nothing unless polled"]pub struct ForEachConcurrent<S, U, F> where
U: IntoFuture, { /* fields omitted */ }
A stream combinator which executes a unit closure over each item on a stream concurrently.
This structure is returned by the Stream::for_each
method.
Trait Implementations
impl<S: Debug, U: Debug, F: Debug> Debug for ForEachConcurrent<S, U, F> where
U: IntoFuture,
U::Future: Debug,
[src]
U: IntoFuture,
U::Future: Debug,
fn fmt(&self, __arg_0: &mut Formatter) -> Result
[src]
Formats the value using the given formatter. Read more
impl<S, U, F> Future for ForEachConcurrent<S, U, F> where
S: Stream,
F: FnMut(S::Item) -> U,
U: IntoFuture<Item = (), Error = S::Error>,
[src]
S: Stream,
F: FnMut(S::Item) -> U,
U: IntoFuture<Item = (), Error = S::Error>,
Auto Trait Implementations
impl<S, U, F> Send for ForEachConcurrent<S, U, F> where
F: Send,
S: Send,
<U as IntoFuture>::Future: Send,
F: Send,
S: Send,
<U as IntoFuture>::Future: Send,
impl<S, U, F> Sync for ForEachConcurrent<S, U, F> where
F: Sync,
S: Sync,
<U as IntoFuture>::Future: Sync,
F: Sync,
S: Sync,
<U as IntoFuture>::Future: Sync,