Removing debugging variable

elastic · Apr 21, 2020 · 15a1383 · 15a1383
1 parent 5ff7219
commit 15a1383
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/libbeat/publisher/pipeline/output_test.go b/libbeat/publisher/pipeline/output_test.go
@@ -51,9 +51,7 @@ func TestMakeClientWorker(t *testing.T) {
 				defer retryer.close()
 
 				var published atomic.Uint
-				var batchCount int
 				publishFn := func(batch publisher.Batch) error {
-					batchCount++
 					published.Add(uint(len(batch.Events())))
 					return nil
 				}
@@ -127,9 +125,7 @@ func TestReplaceClientWorker(t *testing.T) {
 
 				var publishedFirst atomic.Uint
 				blockCtrl := make(chan struct{})
-				var batchCount int
 				blockingPublishFn := func(batch publisher.Batch) error {
-					batchCount++
 					// Emulate blocking. Upon unblocking the in-flight batch that was
 					// blocked is published.
 					if publishedFirst.Load() >= publishLimit {