Function wait_connected

p2p/tests/node.rs:232–241

Waits until a emits event that it is connected to b and b emits an event that it is connected to a.

(a: &mut TestRunner, b: &mut TestRunner)

// Waits until a emits event that it is connected to b
// and b emits an event that it is connected to a.
async fn wait_connected(a: &mut TestRunner, b: &mut TestRunner) {
    while let Some(event) = a.network_events.recv().await {
        match event {
            NetworkEvent::PeerConnected(id) if id == b.peer_id => {
                break;
            }
            _ => {}
        }
    }
}

#[test(tokio::test)]
async fn test_cancel_listen_for_identify() -> Result<()> {