Struct actix::fut::stream::Map [−][src]
#[must_use = "streams do nothing unless polled"]pub struct Map<S, F> { /* fields omitted */ }
Expand description
Stream for the map
method.
Trait Implementations
impl<S, A, F, U> ActorStream<A> for Map<S, F> where
S: ActorStream<A>,
A: Actor,
F: FnMut(S::Item, &mut A, &mut A::Context) -> U,
[src]
impl<S, A, F, U> ActorStream<A> for Map<S, F> where
S: ActorStream<A>,
A: Actor,
F: FnMut(S::Item, &mut A, &mut A::Context) -> U,
[src]Auto Trait Implementations
impl<S, F> RefUnwindSafe for Map<S, F> where
F: RefUnwindSafe,
S: RefUnwindSafe,
impl<S, F> UnwindSafe for Map<S, F> where
F: UnwindSafe,
S: UnwindSafe,
Blanket Implementations
Maps this stream’s items to a different type, returning a new stream of the resulting type. Read more
Computes from this stream’s items new items of a different type using an asynchronous closure. Read more
Execute an accumulating asynchronous computation over a stream, collecting all the values into one final result. Read more
Take elements from this stream while the provided asynchronous predicate
resolves to true
. Read more
Skip elements on this stream while the provided asynchronous predicate
resolves to true
. Read more
Add timeout to stream. Read more
Transforms a stream into a collection, returning a future representing the result of that computation. Read more
Mutably borrows from an owned value. Read more