Skip to content

Commit 90daa0c

Browse files
committed
feat: expose max_missed_blocks method on ProtocolStreamBuilder
1 parent 02fa392 commit 90daa0c

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/evm/stream.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,14 @@ impl ProtocolStreamBuilder {
143143
self
144144
}
145145

146+
/// Sets the maximum number of blocks that can be missed before the stream fails.
147+
pub fn max_missed_blocks(mut self, max_missed_blocks: u64) -> Self {
148+
self.stream_builder = self
149+
.stream_builder
150+
.max_missed_blocks(max_missed_blocks);
151+
self
152+
}
153+
146154
pub async fn build(
147155
self,
148156
) -> Result<impl Stream<Item = Result<Update, StreamDecodeError>>, StreamError> {

0 commit comments

Comments
 (0)