Skip to content

Commit eec9df1

Browse files
committed
Revert "allow for range processor to stop before the main thread"
This reverts commit 544ef09.
1 parent 0ab15cc commit eec9df1

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

src/event_scanner/scanner/common.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -147,10 +147,7 @@ fn spawn_log_consumers_in_stream_mode<N: Network>(
147147
loop {
148148
match range_rx.recv().await {
149149
Ok(message) => {
150-
if tx.send(message).await.is_err() {
151-
debug!("Range processor dropped, stopping range reception");
152-
break;
153-
}
150+
tx.send(message).await.expect("receiver dropped only if we exit this loop");
154151
}
155152
Err(RecvError::Closed) => {
156153
debug!("No more block ranges to receive");

0 commit comments

Comments
 (0)