Fix limit check

subquery · Mar 25, 2024 · a51f17c · a51f17c
1 parent 4e324b1
commit a51f17c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/eth/filters/filter.go b/eth/filters/filter.go
@@ -197,7 +197,7 @@ func (f *Filter) Logs(ctx context.Context) ([]*types.Log, error) {
 			blocks[log.BlockNumber] = true
 		}
 
-		if len(blocks) > int(f.limit) {
+		if len(blocks) >= int(f.limit) {
 			return true
 		}
 

diff --git a/eth/filters/filter_transactions.go b/eth/filters/filter_transactions.go
@@ -178,7 +178,7 @@ func (f *TxFilter) Transactions(ctx context.Context) ([]*ethapi.RPCTransaction,
 			blocks[tx.BlockNumber.ToInt().Uint64()] = true
 		}
 
-		if len(blocks) > int(f.limit) {
+		if len(blocks) >= int(f.limit) {
 			return true
 		}