Struct actix::fut::StreamWrap [−][src]
pub struct StreamWrap<S, A> where
S: Stream, { /* fields omitted */ }
Trait Implementations
type Actor = A
type Actor = A
The actor within which this stream runs.
fn poll_next(
self: Pin<&mut Self>,
_: &mut Self::Actor,
_: &mut <Self::Actor as Actor>::Context,
task: &mut Context<'_>
) -> Poll<Option<Self::Item>>
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
. 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.