Trait actix::fut::stream::ActorStream [−][src]
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
Loading content...Required methods
fn poll_next(
self: Pin<&mut Self>,
srv: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
srv: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
Implementors
impl<A: Actor> ActorStream<A> for IntervalFunc<A>
[src]
type Item = ()
fn poll_next(
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
impl<S, A> ActorStream<A> for StreamWrap<S, A> where
S: Stream,
A: Actor,
[src]
S: Stream,
A: Actor,
type Item = S::Item
fn poll_next(
self: Pin<&mut Self>,
_: &mut A,
_: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
_: &mut A,
_: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
impl<S, A> ActorStream<A> for Timeout<S> where
S: ActorStream<A>,
A: Actor,
[src]
S: ActorStream<A>,
A: Actor,
type Item = Result<S::Item, ()>
fn poll_next(
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Result<S::Item, ()>>>
[src]
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Result<S::Item, ()>>>
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]
S: ActorStream<A>,
A: Actor,
F: FnMut(S::Item, &mut A, &mut A::Context) -> U,
type Item = U
fn poll_next(
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<U>>
[src]
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<U>>
impl<S, A, Fn, F> ActorStream<A> for Then<S, Fn, F::Future> where
S: ActorStream<A>,
A: Actor,
F: IntoActorFuture<A>,
Fn: FnMut(S::Item, &mut A, &mut A::Context) -> F,
[src]
S: ActorStream<A>,
A: Actor,
F: IntoActorFuture<A>,
Fn: FnMut(S::Item, &mut A, &mut A::Context) -> F,
type Item = F::Output
fn poll_next(
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
impl<S, A, Fn, Fut> ActorStream<A> for SkipWhile<S, S::Item, Fn, Fut::Future> where
S: ActorStream<A>,
A: Actor,
Fn: FnMut(&S::Item, &mut A, &mut A::Context) -> Fut,
Fut: IntoActorFuture<A, Output = bool>,
[src]
S: ActorStream<A>,
A: Actor,
Fn: FnMut(&S::Item, &mut A, &mut A::Context) -> Fut,
Fut: IntoActorFuture<A, Output = bool>,
type Item = S::Item
fn poll_next(
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
act: &mut A,
ctx: &mut A::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
impl<S, A, Fut, Fn> ActorStream<A> for TakeWhile<S, S::Item, Fut::Future, Fn> where
S: ActorStream<A>,
A: Actor,
Fn: FnMut(&S::Item, &mut A, &mut A::Context) -> Fut,
Fut: IntoActorFuture<A, Output = bool>,
[src]
S: ActorStream<A>,
A: Actor,
Fn: FnMut(&S::Item, &mut A, &mut A::Context) -> Fut,
Fut: IntoActorFuture<A, Output = bool>,