Trait ListenExt 

pub trait ListenExt: Stream {
    // Provided methods
    fn sleep_on_error(self, delay: Duration) -> SleepOnError<Self>
       where Self: Sized { ... }
    fn listen(self, max_connections: usize) -> Listen<Self>
       where Self: Sized,
             Self::Item: IntoFuture<Item = (), Error = ()> { ... }
}

An extension trait that provides necessary combinators for turning a stream of accept() events into a full-featured connection listener

Usually both sleep_on_error and listen commbinators are used in pair with .map() in-between. See examples for full-featured example.

Provided Methods

fn sleep_on_error(self, delay: Duration) -> SleepOnError<Self>

where Self: Sized,

Turns a listening stream that you can get from TcpListener::incoming into a stream that supresses errors and sleeps on resource shortage, effectively allowing listening stream to resume on error.

fn listen(self, max_connections: usize) -> Listen<Self>

where Self: Sized, Self::Item: IntoFuture<Item = (), Error = ()>,

Turns a stream of protocol handlers usually produced by mapping a stream of accepted cnnec

Implementors

impl<T: Stream> ListenExt for T