Struct actix::fut::StreamTimeout [−][src]
pub struct StreamTimeout<S> where
S: ActorStream + Unpin, { /* fields omitted */ }
Expand description
Future for the timeout
combinator, interrupts computations if it takes
more than timeout
.
This is created by the ActorFuture::timeout()
method.
Trait Implementations
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, ()>>>
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.