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