revert rewind collection change

Author: 0xNeshi

src/event_scanner/scanner/common.rs

@@ -122,9 +122,10 @@ pub fn spawn_log_consumers<N: Network>(
             if let ConsumerMode::CollectLatest { .. } = mode {
                 if !collected.is_empty() {
                     collected.reverse(); // restore chronological order
-                    info!("Sending collected logs to consumer");
-                    _ = sender.try_stream(collected).await;
                 }
+
+                info!("Sending collected logs to consumer");
+                _ = sender.try_stream(collected).await;
             }
         });
 

tests/latest_events/basic.rs

@@ -72,6 +72,9 @@ async fn no_past_events_returns_empty() -> anyhow::Result<()> {
 
     scanner.start().await?;
 
+    let expected: &[TestCounter::CountIncreased] = &[];
+
+    assert_next!(stream, expected);
     assert_closed!(stream);
 
     Ok(())

tests/sync/from_latest.rs

@@ -147,9 +147,13 @@ async fn no_historical_only_live_streams() -> anyhow::Result<()> {
 
     scanner.start().await?;
 
+    // Latest is empty
+    let expected: &[TestCounter::CountIncreased] = &[];
+    assert_next!(stream, expected);
+    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?;