Struct actix::fut::stream::SkipWhile [−][src]
#[must_use = "streams do nothing unless polled"]pub struct SkipWhile<S, I, F, Fut> { /* fields omitted */ }
Expand description
Stream for the skip_while
method.
Trait Implementations
impl<S, A, F, Fut> ActorStream<A> for SkipWhile<S, S::Item, F, Fut> where
S: ActorStream<A>,
A: Actor,
F: FnMut(&S::Item, &mut A, &mut A::Context) -> Fut,
Fut: ActorFuture<A, Output = bool>,
[src]
impl<S, A, F, Fut> ActorStream<A> for SkipWhile<S, S::Item, F, Fut> where
S: ActorStream<A>,
A: Actor,
F: FnMut(&S::Item, &mut A, &mut A::Context) -> Fut,
Fut: ActorFuture<A, Output = bool>,
[src]Auto Trait Implementations
impl<S, I, F, Fut> RefUnwindSafe for SkipWhile<S, I, F, Fut> where
F: RefUnwindSafe,
Fut: RefUnwindSafe,
I: RefUnwindSafe,
S: RefUnwindSafe,
impl<S, I, F, Fut> UnwindSafe for SkipWhile<S, I, F, Fut> where
F: UnwindSafe,
Fut: UnwindSafe,
I: 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