[−][src]Trait actix::fut::ActorStream
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
type Item
The type of item this stream will yield on success.
type Actor: Actor
The actor within which this stream runs.
Required methods
fn poll_next(
self: Pin<&mut Self>,
srv: &mut Self::Actor,
ctx: &mut <Self::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Self::Item>>
self: Pin<&mut Self>,
srv: &mut Self::Actor,
ctx: &mut <Self::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Self::Item>>
Provided methods
fn map<U, F>(self, f: F) -> StreamMap<Self, F> where
F: FnMut(Self::Item, &mut Self::Actor, &mut <Self::Actor as Actor>::Context) -> U,
Self: Sized,
F: FnMut(Self::Item, &mut Self::Actor, &mut <Self::Actor as Actor>::Context) -> U,
Self: Sized,
Converts a stream of type T
to a stream of type U
.
fn then<F, U>(self, f: F) -> StreamThen<Self, F, U> where
F: FnMut(Self::Item, &mut Self::Actor, &mut <Self::Actor as Actor>::Context) -> U,
U: IntoActorFuture<Actor = Self::Actor>,
Self: Unpin + Sized,
F: FnMut(Self::Item, &mut Self::Actor, &mut <Self::Actor as Actor>::Context) -> U,
U: IntoActorFuture<Actor = Self::Actor>,
Self: Unpin + Sized,
Chain on a computation for when a value is ready, passing the resulting
item to the provided closure f
.
fn fold<F, T, Fut>(self, init: T, f: F) -> StreamFold<Self, F, Fut, T> where
F: FnMut(T, Self::Item, &mut Self::Actor, &mut <Self::Actor as Actor>::Context) -> Fut,
Fut: IntoActorFuture<Actor = Self::Actor, Output = T>,
Self: Sized,
F: FnMut(T, Self::Item, &mut Self::Actor, &mut <Self::Actor as Actor>::Context) -> Fut,
Fut: IntoActorFuture<Actor = Self::Actor, Output = T>,
Self: Sized,
Execute an accumulating computation over a stream, collecting all the values into one final result.
fn timeout(self, timeout: Duration) -> StreamTimeout<Self> where
Self: Sized + Unpin,
Self: Sized + Unpin,
Add timeout to stream.
err
value get returned as a timeout error.
fn finish(self) -> StreamFinish<Self> where
Self: Sized + Unpin,
Self: Sized + Unpin,
Converts a stream to a future that resolves when stream finishes.
Implementors
impl<A: Actor> ActorStream for IntervalFunc<A>
[src]
type Item = ()
type Actor = A
fn poll_next(
self: Pin<&mut Self>,
act: &mut Self::Actor,
ctx: &mut <Self::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
act: &mut Self::Actor,
ctx: &mut <Self::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Self::Item>>
impl<S> ActorStream for StreamTimeout<S> where
S: ActorStream + Unpin,
[src]
S: ActorStream + Unpin,
type Item = Result<S::Item, ()>
type Actor = S::Actor
fn poll_next(
self: Pin<&mut Self>,
act: &mut S::Actor,
ctx: &mut <S::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Result<S::Item, ()>>>
[src]
self: Pin<&mut Self>,
act: &mut S::Actor,
ctx: &mut <S::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Result<S::Item, ()>>>
impl<S, A> ActorStream for StreamWrap<S, A> where
S: Stream,
A: Actor,
[src]
S: Stream,
A: Actor,
type Item = S::Item
type Actor = A
fn poll_next(
self: Pin<&mut Self>,
_: &mut Self::Actor,
_: &mut <Self::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Self::Item>>
[src]
self: Pin<&mut Self>,
_: &mut Self::Actor,
_: &mut <Self::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<Self::Item>>
impl<S, F, U> ActorStream for StreamMap<S, F> where
S: ActorStream,
F: FnMut(S::Item, &mut S::Actor, &mut <S::Actor as Actor>::Context) -> U,
[src]
S: ActorStream,
F: FnMut(S::Item, &mut S::Actor, &mut <S::Actor as Actor>::Context) -> U,
type Item = U
type Actor = S::Actor
fn poll_next(
self: Pin<&mut Self>,
act: &mut Self::Actor,
ctx: &mut <S::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<U>>
[src]
self: Pin<&mut Self>,
act: &mut Self::Actor,
ctx: &mut <S::Actor as Actor>::Context,
task: &mut Context
) -> Poll<Option<U>>
impl<S, F: 'static, U> ActorStream for StreamThen<S, F, U> where
S: ActorStream + Unpin,
F: FnMut(S::Item, &mut S::Actor, &mut <S::Actor as Actor>::Context) -> U,
U: IntoActorFuture<Actor = S::Actor>,
U::Future: Unpin,
[src]
S: ActorStream + Unpin,
F: FnMut(S::Item, &mut S::Actor, &mut <S::Actor as Actor>::Context) -> U,
U: IntoActorFuture<Actor = S::Actor>,
U::Future: Unpin,