fix race

disq · disq · commit 6b5585607130 · 2025-06-09T14:39:03.000+01:00
diff --git a/writers/streamingbatchwriter/streamingbatchwriter.go b/writers/streamingbatchwriter/streamingbatchwriter.go
@@ -425,7 +425,6 @@ func (s *streamingWorkerManager[T]) send(ctx context.Context, data T) {
 			if s.inputCh == ch { // only close if we're still the active channel
 				close(s.inputCh)
 				s.inputCh = nil
-				s.limit.Reset()
 			}
 		}()
 

Original file line number	Diff line number	Diff line change
`@@ -425,7 +425,6 @@ func (s *streamingWorkerManager[T]) send(ctx context.Context, data T) {`
`425`	`425`	`if s.inputCh == ch { // only close if we're still the active channel`
`426`	`426`	`close(s.inputCh)`
`427`	`427`	`s.inputCh = nil`
`428`		`- s.limit.Reset()`
`429`	`428`	`}`
`430`	`429`	`}()`
`431`	`430`