it is a naiive thing

replicator/replicator_test.go

@@ -58,12 +58,12 @@ func TestReplicatorStream(t *testing.T) {
 
 			wg := &sync.WaitGroup{}
 			wg.Add(1)
-			go func() {
+			go func(t *testing.T) {
 				defer wg.Done()
 				if err := replicator.Stream(ctx); err != nil && !errors.Is(err, ctx.Err()) {
 					t.Fatal(err)
 				}
-			}()
+			}(t)
 			if c.during != nil {
 				c.during(t, replicator)
 			}