pub async fn run_incoming<I>(self, incoming: I)
    where
        I: TryStream + Send,
        I::Ok: AsyncRead + AsyncWrite + Send + 'static + Unpin,
        I::Error: Into<Box<dyn StdError + Send + Sync>>,
    {
        self.run_incoming2(incoming.map_ok(crate::transport::LiftIo).into_stream()).await;
    }
/// Run this `Server` forever on the current thread with a specific stream
/// of incoming connections.
///
/// This can be used for Unix Domain Sockets, or TLS, etc.
Run this `Server` forever on the current thread with a specific stream
of incoming connections.

This can be used for Unix Domain Sockets, or TLS, etc.
Run this ` Server ` forever on the current thread with a specific stream of incoming connections . This can be used for Unix Domain Sockets or TLS etc .
pub async fn run_incoming<I>(self, incoming: I)
    where
        I: TryStream + Send,
        I::Ok: AsyncRead + AsyncWrite + Send + 'static + Unpin,
        I::Error: Into<Box<dyn StdError + Send + Sync>>,
    {
        self.run_incoming2(incoming.map_ok(crate::transport::LiftIo).into_stream()).await;
    }
pub async fn run_incoming < I > ( self , incoming : I ) where I : TryStream + Send , I :: Ok : AsyncRead + AsyncWrite + Send + ' static + Unpin , I :: Error : Into < Box < dyn StdError + Send + Sync > > , { self . run_incoming2 ( incoming . map_ok ( crate :: transport :: LiftIo ) . into_stream ( ) ) . await ; }
Run this `Server` forever on the current thread with a specific stream
of incoming connections.
Run this ` Server ` forever on the current thread with a specific stream of incoming connections .
self
incoming
I