From 0f91a00217126b0ef7cad8ec3f35a0b7167db73e Mon Sep 17 00:00:00 2001
From: Charles Billette <charles@cbillette.com>
Date: Thu, 21 Nov 2024 09:58:05 -0500
Subject: [PATCH] Add MaxStopBlock variable to blockpoller

Introduce a MaxStopBlock variable to be used in the BlockPoller. This change helps manage the upper limit for block polling, allowing more flexibility and control over the polling process.
---
 blockpoller/poller.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/blockpoller/poller.go b/blockpoller/poller.go
index 3daaed8..040e267 100644
--- a/blockpoller/poller.go
+++ b/blockpoller/poller.go
@@ -73,6 +73,8 @@ func New[C any](
 	return b
 }
 
+var MaxStopBlock *uint64 = nil
+
 func (p *BlockPoller[C]) Run(firstStreamableBlockNum uint64, stopBlock *uint64, blockFetchBatchSize int) error {
 	p.startBlockNumGate = firstStreamableBlockNum
 	p.logger.Info("starting poller",