mirror of
https://github.com/hexedtech/codemp.git
synced 2024-11-24 16:14:48 +01:00
test: wait more
This commit is contained in:
parent
0e68e89ce8
commit
e4c81c0d0d
1 changed files with 4 additions and 4 deletions
|
@ -336,8 +336,8 @@ 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,
|
||||
|
@ -345,8 +345,8 @@ async fn test_content_converges() {
|
|||
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,
|
||||
|
|
Loading…
Reference in a new issue