We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0b7df04 commit b535c57Copy full SHA for b535c57
src/block_range_scanner.rs
@@ -583,8 +583,11 @@ impl<N: Network> Service<N> {
583
Ok(ws_stream) => {
584
info!("WebSocket connected for live blocks");
585
586
- let cur = expected_next_block;
587
- let mut stream = ws_stream.into_stream().skip_while(|header| header.number() < cur);
+ // ensure we start streaming only after the expected_next_block cutoff
+ let cutoff = expected_next_block;
588
+ let mut stream =
589
+ ws_stream.into_stream().skip_while(|header| header.number() < cutoff);
590
+
591
while let Some(incoming_block) = stream.next().await {
592
let incoming_block_num = incoming_block.number();
593
info!(block_number = incoming_block_num, "Received block header");
0 commit comments