Struct tokio::util::future::AwaitStream

pub struct AwaitStream<T: Stream> {
    // some fields omitted
}

Wait on a given stream to complete the next value

Methods

impl<T: Stream> AwaitStream<T>

fn new(stream: T) -> Result<AwaitStream<T>>

Create a new await for the given future

fn poll(&mut self) -> Option<Result<Option<T::Item>, T::Error>>

Poll for the completed value.

Trait Implementations

impl<T: Stream> Readiness for AwaitStream<T>

fn is_readable(&self) -> bool

Returns true if the value is currently readable.

fn is_writable(&self) -> bool

Returns true if the value is currently writable.