Trait actix::fut::stream::ActorStream [−][src]
pub trait ActorStream<A: Actor> { type Item; fn poll_next(
self: Pin<&mut Self>,
srv: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>; }
Expand description
A stream of values, not all of which may have been produced yet.
This is similar to futures_util::stream::Stream
trait, except it works with Actor
Associated Types
Required methods
Implementors
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]impl<S, A, F, Fut> ActorStream<A> for TakeWhile<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 TakeWhile<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 Then<S, F, Fut> where
S: ActorStream<A>,
A: Actor,
F: FnMut(S::Item, &mut A, &mut A::Context) -> Fut,
Fut: ActorFuture<A>,
[src]
impl<S, A, F, Fut> ActorStream<A> for Then<S, F, Fut> where
S: ActorStream<A>,
A: Actor,
F: FnMut(S::Item, &mut A, &mut A::Context) -> Fut,
Fut: ActorFuture<A>,
[src]