pub fn incoming(&self) -> impl Stream<Item = Result<TcpStream>> + Unpin + '_ {
        Box::pin(stream::unfold(self, |listener| async move {
            let res = listener.accept().await;
            Some((res, listener))
        }))
    }
/// Creates a stream of incoming connections
///
/// # Examples
///
/// ```no_run
/// use futures_lite::stream::StreamExt;
/// use glommio::{net::TcpListener, LocalExecutor};
///
/// let ex = LocalExecutor::default();
/// ex.run(async move {
///     let listener = TcpListener::bind("127.0.0.1:8000").unwrap();
///     let mut incoming = listener.incoming();
///     while let Some(conn) = incoming.next().await {
///         println!("Accepted client: {:?}", conn);
///     }
/// });
/// ```
Creates a stream of incoming connections
Creates a stream of incoming connections
pub fn incoming(&self) -> impl Stream<Item = Result<TcpStream>> + Unpin + '_ {
        Box::pin(stream::unfold(self, |listener| async move {
            let res = listener.accept().await;
            Some((res, listener))
        }))
    }
pub fn incoming ( & self ) -> impl Stream < Item = Result < TcpStream > > + Unpin + ' _ { Box :: pin ( stream :: unfold ( self , | listener | async move { let res = listener . accept ( ) . await ; Some ( ( res , listener ) ) } ) ) }
Creates a stream of incoming connections
Creates a stream of incoming connections
&self
&self
examples
```no_run
use futures_lite::stream::StreamExt;
use glommio::{net::TcpListener, LocalExecutor}.

let ex = LocalExecutor::default();
ex.run(async move {
let listener = TcpListener::bind("127.0.0.1:8000").unwrap();
let mut incoming = listener.incoming();
while let Some(conn) = incoming.next().await {
println!("Accepted client: {:?}", conn);
}
});
```
` ` ` no_run use futures_lite :: stream :: StreamExt ; use glommio :: { net :: TcpListener LocalExecutor } . let ex = LocalExecutor :: default () ; ex . run ( async move { let listener = TcpListener :: bind ( " 127 . 0 . 0 . 1 : 8000 " ) . unwrap () ; let mut incoming = listener . incoming () ; while let Some ( conn ) = incoming . next () . await { println! ( " Accepted client : { : ? } " conn ) ; } } ) ; ` ` `