Skip to content

Commit 4fec1e2

Browse files
committed
revert change to max_block_range validation
1 parent 145d80e commit 4fec1e2

File tree

3 files changed

+3
-4
lines changed

3 files changed

+3
-4
lines changed

src/block_range_scanner.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -166,9 +166,6 @@ impl BlockRangeScanner {
166166
self,
167167
provider: impl IntoRobustProvider<N>,
168168
) -> Result<ConnectedBlockRangeScanner<N>, ScannerError> {
169-
if self.max_block_range == 0 {
170-
return Err(ScannerError::InvalidMaxBlockRange);
171-
}
172169
let provider = provider.into_robust_provider().await?;
173170
Ok(ConnectedBlockRangeScanner {
174171
provider,

src/event_scanner/scanner/mod.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -465,6 +465,9 @@ impl<M> EventScannerBuilder<M> {
465465
self,
466466
provider: impl IntoRobustProvider<N>,
467467
) -> Result<EventScanner<M, N>, ScannerError> {
468+
if self.block_range_scanner.max_block_range == 0 {
469+
return Err(ScannerError::InvalidMaxBlockRange);
470+
}
468471
let block_range_scanner = self.block_range_scanner.connect::<N>(provider).await?;
469472
Ok(EventScanner { config: self.config, block_range_scanner, listeners: Vec::new() })
470473
}

src/robust_provider/builder.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@ impl<N: Network, P: IntoRootProvider<N>> Debug for RobustProviderBuilder<N, P> {
4646
.field("max_retries", &self.max_retries)
4747
.field("min_delay", &self.min_delay)
4848
.field("reconnect_interval", &self.reconnect_interval)
49-
.field("subscription_buffer_capacity", &self.subscription_buffer_capacity)
5049
.finish()
5150
}
5251
}

0 commit comments

Comments
 (0)