Struct futures::stream::ForEach
[−]
[src]
#[must_use = "streams do nothing unless polled"]pub struct ForEach<S, U, F> where
U: IntoFuture, { /* fields omitted */ }
A stream combinator which executes a unit closure over each item on a stream.
This structure is returned by the Stream::for_each
method.
Trait Implementations
impl<S, U, F> Future for ForEach<S, U, F> where
F: FnMut(<S as Stream>::Item) -> U,
S: Stream,
U: IntoFuture<Item = (), Error = <S as Stream>::Error>,
[src]
F: FnMut(<S as Stream>::Item) -> U,
S: Stream,
U: IntoFuture<Item = (), Error = <S as Stream>::Error>,
type Item = S
A successful value
type Error = <S as Stream>::Error
An error
fn poll(&mut self, cx: &mut Context) -> Result<Async<S>, <S as Stream>::Error>
[src]
Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available. Read more
impl<S, U, F> Debug for ForEach<S, U, F> where
F: Debug,
S: Debug,
U: Debug + IntoFuture,
<U as IntoFuture>::Future: Debug,
[src]
F: Debug,
S: Debug,
U: Debug + IntoFuture,
<U as IntoFuture>::Future: Debug,