From 57c0f9281dd5f51d0bcf58e0dd3b6891a114d93e Mon Sep 17 00:00:00 2001 From: martyall Date: Sat, 7 Oct 2023 13:12:00 -0700 Subject: [PATCH] maybe correct? --- src/Network/Ethereum/Web3/Contract/Events.purs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/Network/Ethereum/Web3/Contract/Events.purs b/src/Network/Ethereum/Web3/Contract/Events.purs index a27118e..a156716 100644 --- a/src/Network/Ethereum/Web3/Contract/Events.purs +++ b/src/Network/Ethereum/Web3/Contract/Events.purs @@ -191,7 +191,7 @@ filterProducer cs@(MultiFilterStreamState currentState@{ windowSize, currentBloc nextAvailableBlock = over BlockNumber (_ - fromInt currentState.trailBy) chainHead in { nextEndBlock: min targetEnd nextAvailableBlock, finalBlock: Just targetEnd } - isFinished = maybe false (\final -> currentBlock >= final) finalBlock + isFinished = maybe false (\final -> currentBlock > final) finalBlock if isFinished then pure cs else if chainHead < currentBlock then waitForMoreBlocks else continueTo nextEndBlock @@ -210,8 +210,7 @@ filterProducer cs@(MultiFilterStreamState currentState@{ windowSize, currentBloc modify :: forall (k :: Type) (e :: k). Filter e -> Filter e modify fltr = fltr # _fromBlock .~ BN currentBlock - # _toBlock - .~ BN endBlock + # _toBlock .~ BN endBlock fs' = hmap (ModifyFilter modify) currentFilters yieldT fs'