From f7a1ab627c4f8c522dde79968a21895f1debc469 Mon Sep 17 00:00:00 2001 From: link2xt Date: Sat, 18 May 2024 23:09:34 +0000 Subject: [PATCH] wait for connect instead of sleep --- src/peer_channels.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/peer_channels.rs b/src/peer_channels.rs index 9b3278756..321a6f95a 100644 --- a/src/peer_channels.rs +++ b/src/peer_channels.rs @@ -771,8 +771,9 @@ mod tests { eprintln!("Sending advertisements"); // Alice advertises herself. - send_webxdc_realtime_advertisement(alice, alice_webxdc.id) + let alice_advertisement_future = send_webxdc_realtime_advertisement(alice, alice_webxdc.id) .await + .unwrap() .unwrap(); let alice_advertisement = alice.pop_sent_msg().await; @@ -785,8 +786,10 @@ mod tests { bob.recv_msg_trash(&alice_advertisement).await; alice.recv_msg_trash(&bob_advertisement).await; + eprintln!("Alice waits for connection"); + alice_advertisement_future.await; + // Alice sends ephemeral message - tokio::time::sleep(tokio::time::Duration::from_secs(10)).await; eprintln!("Sending ephemeral message"); send_webxdc_realtime_data(alice, alice_webxdc.id, b"alice -> bob".into()) .await