From e0b919bae81c19c2fc5bb241b523c8683d02ace3 Mon Sep 17 00:00:00 2001 From: alemi Date: Wed, 30 Oct 2024 14:22:51 +0100 Subject: [PATCH] fix: more time in tryRecv to compensate longer RTT --- src/tests/client.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/tests/client.rs b/src/tests/client.rs index 08a8d91..db78a1c 100644 --- a/src/tests/client.rs +++ b/src/tests/client.rs @@ -100,8 +100,8 @@ async fn test_content_converges() { // TODO is there a nicer way to make sure we received all changes? - for i in 0..100 { - tokio::time::sleep(std::time::Duration::from_millis(50)).await; + for i in 0..20 { + tokio::time::sleep(std::time::Duration::from_millis(200)).await; match bob.try_recv().await? { Some(change) => bob.ack(change.version), None => break, @@ -109,8 +109,8 @@ async fn test_content_converges() { eprintln!("bob more to recv at attempt #{i}"); } - for i in 0..100 { - tokio::time::sleep(std::time::Duration::from_millis(50)).await; + for i in 0..20 { + tokio::time::sleep(std::time::Duration::from_millis(200)).await; match alice.try_recv().await? { Some(change) => alice.ack(change.version), None => break,