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.

Loading content...

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.

Loading content...

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>

Loading content...