hexedtech/codemp
3
0
Fork 0
mirror of https://github.com/hexedtech/codemp.git synced 2024-11-22 07:14:50 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: more time in tryRecv to compensate longer RTT

Browse source
This commit is contained in:
əlemi 2024-10-30 14:22:51 +01:00
parent 90568bba8d
commit e0b919bae8
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/tests/client.rs
View file

@ -100,8 +100,8 @@ async fn test_content_converges() {
// TODO is there a nicer way to make sure we received all changes? // TODO is there a nicer way to make sure we received all changes?
for i in 0..100 { for i in 0..20 {
tokio::time::sleep(std::time::Duration::from_millis(50)).await; tokio::time::sleep(std::time::Duration::from_millis(200)).await;
match bob.try_recv().await? { match bob.try_recv().await? {
Some(change) => bob.ack(change.version), Some(change) => bob.ack(change.version),
None => break, None => break,
@ -109,8 +109,8 @@ async fn test_content_converges() {
eprintln!("bob more to recv at attempt #{i}"); eprintln!("bob more to recv at attempt #{i}");
} }
for i in 0..100 { for i in 0..20 {
tokio::time::sleep(std::time::Duration::from_millis(50)).await; tokio::time::sleep(std::time::Duration::from_millis(200)).await;
match alice.try_recv().await? { match alice.try_recv().await? {
Some(change) => alice.ack(change.version), Some(change) => alice.ack(change.version),
None => break, None => break,