Trait tower_web::net::ConnectionStream

pub trait ConnectionStream {
    type Item: Connection;
    fn poll_next(&mut self) -> Poll<Option<Self::Item>, Error>;
}

An asynchronous stream of connections.

Associated Types

type Item: Connection

Connection type yielded each iteration.

Required Methods

fn poll_next(&mut self) -> Poll<Option<Self::Item>, Error>

Attempt to resolve the next connection, registering the current task for wakeup if one is not yet available.

Implementors

impl<T> ConnectionStream for T where     T: Stream<Error = Error>,     T::Item: Connection,

type Item = Self::Item

fn poll_next(&mut self) -> Poll<Option<Self::Item>, Error>