pub(crate) async fn next_incoming(&self) -> Either<Connection, Multiaddr> {
        // The `expect` below can panic if the background task has stopped. The background task
        // can stop only if the `Endpoint` is destroyed or if the task itself panics. In other
        // words, we panic here iff a panic has already happened somewhere else, which is a
        // reasonable thing to do.
        let mut new_connections = self.new_connections.lock().await;
        new_connections
            .next()
            .await
            .expect("background task has crashed")
    }
/// Tries to pop a new incoming connection from the queue.
Tries to pop a new incoming connection from the queue.
Tries to pop a new incoming connection from the queue .
pub(crate) async fn next_incoming(&self) -> Either<Connection, Multiaddr> {
        // The `expect` below can panic if the background task has stopped. The background task
        // can stop only if the `Endpoint` is destroyed or if the task itself panics. In other
        // words, we panic here iff a panic has already happened somewhere else, which is a
        // reasonable thing to do.
        let mut new_connections = self.new_connections.lock().await;
        new_connections
            .next()
            .await
            .expect("background task has crashed")
    }
pub ( crate ) async fn next_incoming ( & self ) -> Either < Connection , Multiaddr > { // The `expect` below can panic if the background task has stopped. The background task // can stop only if the `Endpoint` is destroyed or if the task itself panics. In other // words, we panic here iff a panic has already happened somewhere else, which is a // reasonable thing to do. let mut new_connections = self . new_connections . lock ( ) . await ; new_connections . next ( ) . await . expect ( " " ) }
Tries to pop a new incoming connection from the queue.
Tries to pop a new incoming connection from the queue .
&self
&self