Trait ConnectionStream

pub trait ConnectionStream {
    type Item: Connection;

    // Required method
    fn poll_next(&mut self) -> Poll<Option<Self::Item>, Error>;
}

An asynchronous stream of connections.

Required 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 = <T as Stream>::Item