add sleeps before asserts in from_latest tests to allow scanner to switch to live

Author: 0xNeshi

tests/sync/from_latest.rs

@@ -1,4 +1,6 @@
 use alloy::{primitives::U256, providers::ext::AnvilApi};
+use std::time::Duration;
+use tokio::time::sleep;
 
 use crate::common::{TestCounter, setup_sync_from_latest_scanner};
 use event_scanner::{Notification, assert_empty, assert_event_sequence_final, assert_next};
@@ -114,8 +116,11 @@ async fn exact_historical_count_then_live() -> anyhow::Result<()> {
     assert_next!(stream, Notification::SwitchingToLive);
     let mut stream = assert_empty!(stream);
 
+    // give scanner time to subscribe to live events
+    sleep(Duration::from_millis(10)).await;
     // Live continues
     contract.increase().send().await?.watch().await?;
+
     assert_next!(stream, &[TestCounter::CountIncreased { newCount: U256::from(5) }]);
     assert_empty!(stream);
 
@@ -137,6 +142,8 @@ async fn no_historical_only_live_streams() -> anyhow::Result<()> {
     assert_next!(stream, Notification::SwitchingToLive);
     let mut stream = assert_empty!(stream);
 
+    // give scanner time to start
+    sleep(Duration::from_millis(10)).await;
     // Live events arrive
     contract.increase().send().await?.watch().await?;
     contract.increase().send().await?.watch().await?;
@@ -184,6 +191,8 @@ async fn block_gaps_do_not_affect_number_of_events_streamed() -> anyhow::Result<
     assert_next!(stream, Notification::SwitchingToLive);
     let mut stream = assert_empty!(stream);
 
+    // give scanner time to start
+    sleep(Duration::from_millis(10)).await;
     // Immediately produce a new live event in a new block
     contract.increase().send().await?.watch().await?;