Skip to content

Commit ecd7327

Browse files
committed
revert rewind collection change
1 parent 2c2b631 commit ecd7327

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

src/event_scanner/scanner/common.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -120,11 +120,9 @@ pub fn spawn_log_consumers<N: Network>(
120120
}
121121

122122
if let ConsumerMode::CollectLatest { .. } = mode {
123-
if collected.is_empty() {
124-
info!("No latest logs collected");
125-
} else {
126-
info!("Sending collected logs to consumer");
123+
if !collected.is_empty() {
127124
collected.reverse(); // restore chronological order
125+
info!("Sending collected logs to consumer");
128126
_ = sender.try_stream(collected).await;
129127
}
130128
}

0 commit comments

Comments
 (0)