diff options
Diffstat (limited to 'tests/sync/live_sync.rs')
| -rw-r--r-- | tests/sync/live_sync.rs | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/tests/sync/live_sync.rs b/tests/sync/live_sync.rs index ebe1c0b..7fa08a0 100644 --- a/tests/sync/live_sync.rs +++ b/tests/sync/live_sync.rs | |||
| @@ -229,7 +229,10 @@ async fn test_live_sync_layer3_events() { | |||
| 229 | .send_event(&comment) | 229 | .send_event(&comment) |
| 230 | .await | 230 | .await |
| 231 | .expect("Failed to send comment"); | 231 | .expect("Failed to send comment"); |
| 232 | println!("Layer 3 comment {} sent to relay_a BEFORE Layer 3 subscription established", comment_id); | 232 | println!( |
| 233 | "Layer 3 comment {} sent to relay_a BEFORE Layer 3 subscription established", | ||
| 234 | comment_id | ||
| 235 | ); | ||
| 233 | 236 | ||
| 234 | // 6. Now wait for issue to sync to relay_b (this triggers Layer 3 filter creation) | 237 | // 6. Now wait for issue to sync to relay_b (this triggers Layer 3 filter creation) |
| 235 | tokio::time::sleep(Duration::from_secs(2)).await; | 238 | tokio::time::sleep(Duration::from_secs(2)).await; |
| @@ -394,7 +397,7 @@ async fn test_live_sync_event_ordering() { | |||
| 394 | client_a | 397 | client_a |
| 395 | .send_event(&issue) | 398 | .send_event(&issue) |
| 396 | .await | 399 | .await |
| 397 | .expect(&format!("Failed to send issue {}", i)); | 400 | .unwrap_or_else(|_| panic!("Failed to send issue {}", i)); |
| 398 | 401 | ||
| 399 | // Delay between events to ensure different timestamps | 402 | // Delay between events to ensure different timestamps |
| 400 | tokio::time::sleep(Duration::from_millis(150)).await; | 403 | tokio::time::sleep(Duration::from_millis(150)).await; |