Struct actix::fut::StreamWrap[][src]

pub struct StreamWrap<S, A> where
    S: Stream
{ /* fields omitted */ }

Trait Implementations

impl<S, A> ActorStream for StreamWrap<S, A> where
    S: Stream,
    A: Actor
[src]

The type of item this stream will yield on success.

The type of error this stream may generate.

The actor within which this stream runs.

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

Converts a stream of error type T to a stream of error type E.

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

Chain on a computation for when a value is ready, passing the successful results to the provided closure f. Read more

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

Add timeout to stream. Read more

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

Auto Trait Implementations

impl<S, A> Send for StreamWrap<S, A> where
    A: Send,
    S: Send

impl<S, A> Sync for StreamWrap<S, A> where
    A: Sync,
    S: Sync