Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-09 01:46:30 +03:00
Code Issues Packages Projects Releases Wiki Activity

wait for connect instead of sleep

Browse Source
This commit is contained in:
link2xt
2024-05-18 23:09:34 +00:00
parent 4bed4b32f5
commit f7a1ab627c
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/peer_channels.rs
View File

@@ -771,8 +771,9 @@ mod tests {
eprintln!("Sending advertisements"); eprintln!("Sending advertisements");
// Alice advertises herself. // Alice advertises herself.
send_webxdc_realtime_advertisement(alice, alice_webxdc.id) let alice_advertisement_future = send_webxdc_realtime_advertisement(alice, alice_webxdc.id)
.await .await
.unwrap()
.unwrap(); .unwrap();
let alice_advertisement = alice.pop_sent_msg().await; let alice_advertisement = alice.pop_sent_msg().await;
@@ -785,8 +786,10 @@ mod tests {
bob.recv_msg_trash(&alice_advertisement).await; bob.recv_msg_trash(&alice_advertisement).await;
alice.recv_msg_trash(&bob_advertisement).await; alice.recv_msg_trash(&bob_advertisement).await;
eprintln!("Alice waits for connection");
alice_advertisement_future.await;
// Alice sends ephemeral message // Alice sends ephemeral message
tokio::time::sleep(tokio::time::Duration::from_secs(10)).await;
eprintln!("Sending ephemeral message"); eprintln!("Sending ephemeral message");
send_webxdc_realtime_data(alice, alice_webxdc.id, b"alice -> bob".into()) send_webxdc_realtime_data(alice, alice_webxdc.id, b"alice -> bob".into())
.await .await