fast.rs

// This concludes immediatlly, as expected
#[async_std::test]
async fn test_listerner_client() {
    let addr = next_test_ip4();

    // setup listener
    let listener = UtpListener::bind(addr).await.unwrap();
    // spawn a background task waiting for the connection
    task::spawn(async move { listener.accept().await.unwrap() });

    // Connect to the server
    let client = task::spawn(async move {
        UtpSocket::connect(addr).await.unwrap();
    });

    // await tasks to conclude
    client.await;
}

slow.rs

// This takes over 60s to run, but eventually concludes
#[async_std::test]
async fn test_listerner_client() {
    let addr = next_test_ip4();

    // setup listener
    let listener = UtpListener::bind(addr).await.unwrap();
    // spawn a background task waiting for the connection
    let server = task::spawn(async move { listener.accept().await.unwrap() });

    // Connect to the server
    let client = task::spawn(async move {
        UtpSocket::connect(addr).await.unwrap();
    });

    // await tasks to conclude
    client.await;
    server.await;
}