refactor: Reset timer in batchBuilder

ethpandaops · Oct 23, 2023 · 6ff8770 · 6ff8770
1 parent 0c5054a
commit 6ff8770
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/processor/batch.go b/pkg/processor/batch.go
@@ -382,6 +382,8 @@ func (bvp *BatchItemProcessor[T]) batchBuilder(ctx context.Context) {
 				bvp.batchReady <- true
 			}
 
+			bvp.timer.Reset(bvp.o.BatchTimeout)
+
 			bvp.batchMutex.Unlock()
 		}
 	}