Skip to content

Commit

Permalink
Merge pull request #75 from hexedtech/test/wait-more
Browse files Browse the repository at this point in the history
test: wait more
  • Loading branch information
alemidev authored Nov 19, 2024
2 parents 0e68e89 + e4c81c0 commit 293bdcd
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/tests/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -336,17 +336,17 @@ async fn test_content_converges() {
tokio::time::sleep(std::time::Duration::from_secs(1)).await;

// TODO is there a nicer way to make sure we received all changes?
for i in 0..20 {
tokio::time::sleep(std::time::Duration::from_millis(200)).await;
for i in 0..5 {
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
match bob.try_recv().await? {
Some(change) => bob.ack(change.version),
None => break,
}
eprintln!("bob more to recv at attempt #{i}");
}

for i in 0..20 {
tokio::time::sleep(std::time::Duration::from_millis(200)).await;
for i in 0..5 {
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
match alice.try_recv().await? {
Some(change) => alice.ack(change.version),
None => break,
Expand Down

0 comments on commit 293bdcd

Please sign in to comment.