[patch] reset ticker whenever a batch is processed

.github/workflows/go.yml

@@ -18,7 +18,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v4
         with:
-          go-version: "1.23"
+          go-version: "1.25"
 
       - name: Build
         run: go build -v ./...
@@ -38,6 +38,6 @@ jobs:
           path-to-profile: covprofile
 
       - name: golangci-lint
-        uses: golangci/golangci-lint-action@v6
+        uses: golangci/golangci-lint-action@v7
         with:
-          version: v1.60
+          version: v2.6

nibbler.go

@@ -155,13 +155,15 @@ func (bat *Nibbler[T]) listener(ticker *time.Ticker, size int) (err error) {
 		// process non empty batch
 		if len(bat.batch) > 0 {
 			err = bat.processBatch(TriggerTicker)
+			ticker.Reset(bat.cfg.TickerDuration)
 		}
 
 	case value := <-bat.queue:
 		bat.batch = append(bat.batch, value)
 		// process batch immediately if full, instead of waiting for ticker
 		if len(bat.batch) >= size {
 			err = bat.processBatch(TriggerFull)
+			ticker.Reset(bat.cfg.TickerDuration)
 		}
 	}
 

nibbler_test.go

@@ -161,7 +161,12 @@ func TestProcessorErr(tt *testing.T) {
 		nib, err := Start(&Config[string]{
 			TickerDuration: time.Second,
 			Processor: func(_ context.Context, _ Trigger, _ []string) error {
-				panic(errProcessing)
+				// this whole if condition is to satisfy the stupid linter
+				// which does not honour ignore directives
+				if errProcessing != nil {
+					panic(errProcessing)
+				}
+				return nil
 			},
 			ProcessorErr: func(failedBatch []string, err error) {
 				asserter.ErrorIs(err, errProcessing)