Move waitgroup.Add outside goroutine

2026-02-24 11:48:40 -05:00 · 2026-02-24 11:48:40 -05:00 · e6b827a1fc
commit e6b827a1fc
parent a8176ab4fe
1 changed files with 1 additions and 1 deletions
--- a/cmd/kt-server/stream.go
+++ b/cmd/kt-server/stream.go
@ -120,8 +120,8 @@ func (s *Streamer) run(ctx context.Context, name string, startAtTimestamp time.T
 			// checkpointing past an update that we might've failed to sequence.
 			state.sinceLast += 1
 			state.wg.Add(1)
+			updatesWg.Add(1)
 			go func(ctx context.Context, data []byte, wg *sync.WaitGroup) {
-				updatesWg.Add(1)
 				defer updatesWg.Done()
 				for {
 					select {