Trait actix::fut::ActorStream[−][src]

pub trait ActorStream {
    type Item;
    type Actor: Actor;
    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>>;

    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,
    { ... }

    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,
    { ... }

    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,
    { ... }

    fn timeout(self, timeout: Duration) -> StreamTimeout<Self>
    where
        Self: Sized + Unpin,
    { ... }

    fn finish(self) -> StreamFinish<Self>
    where
        Self: Sized + Unpin,
    { ... }
}
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

The type of item this stream will yield on success.

The actor within which this stream runs.

Required methods

Provided methods

Converts a stream of type T to a stream of type U.

Chain on a computation for when a value is ready, passing the resulting item to the provided closure f.

Execute an accumulating computation over a stream, collecting all the values into one final result.

Add timeout to stream.

err value get returned as a timeout error.

Converts a stream to a future that resolves when stream finishes.

Implementors