pub fn serve_incoming<I>(self, incoming: I) -> impl Future<Output = ()> + 'static
    where
        I: TryStream + Send + 'static,
        I::Ok: AsyncRead + AsyncWrite + Send + 'static + Unpin,
        I::Error: Into<Box<dyn StdError + Send + Sync>>,
    {
        let incoming = incoming.map_ok(crate::transport::LiftIo);
        self.serve_incoming2(incoming)
    }
/// Setup this `Server` with a specific stream of incoming connections.
///
/// This can be used for Unix Domain Sockets, or TLS, etc.
///
/// Returns a `Future` that can be executed on any runtime.
Setup this `Server` with a specific stream of incoming connections.
This can be used for Unix Domain Sockets, or TLS, etc.

Returns a `Future` that can be executed on any runtime.
Setup this ` Server ` with a specific stream of incoming connections . This can be used for Unix Domain Sockets or TLS etc . Returns a ` Future ` that can be executed on any runtime .
pub fn serve_incoming<I>(self, incoming: I) -> impl Future<Output = ()> + 'static
    where
        I: TryStream + Send + 'static,
        I::Ok: AsyncRead + AsyncWrite + Send + 'static + Unpin,
        I::Error: Into<Box<dyn StdError + Send + Sync>>,
    {
        let incoming = incoming.map_ok(crate::transport::LiftIo);
        self.serve_incoming2(incoming)
    }
pub fn serve_incoming < I > ( self , incoming : I ) -> impl Future < Output = ( ) > + ' static where I : TryStream + Send + ' static , I :: Ok : AsyncRead + AsyncWrite + Send + ' static + Unpin , I :: Error : Into < Box < dyn StdError + Send + Sync > > , { let incoming = incoming . map_ok ( crate :: transport :: LiftIo ) ; self . serve_incoming2 ( incoming ) }
Setup this `Server` with a specific stream of incoming connections.
Setup this ` Server ` with a specific stream of incoming connections .
self
incoming
I