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 90d24dc commit b5cebf8Copy full SHA for b5cebf8
src/block_range_scanner/common.rs
@@ -80,10 +80,11 @@ async fn get_first_block<
80
match first_block {
81
Ok(block) => return Some(block),
82
Err(e) => {
83
- error!(error = %e, "Error receiving block from stream");
84
match e {
85
subscription::Error::Lagged(_) => {
86
- continue;
+ // scanner already accounts for skipped block numbers
+ // next block will be the actual incoming block
87
+ info!("Skipping Error::Lagged, next block should be the first live block");
88
}
89
subscription::Error::Timeout => {
90
_ = sender.try_stream(ScannerError::Timeout).await;
@@ -99,7 +100,7 @@ async fn get_first_block<
99
100
101
102
- };
103
+ }
104
105
106
None
0 commit comments