update(TestRace): minor changes

b97tsk · Jun 28, 2024 · 5f22cd4 · 5f22cd4
1 parent 343c9b6
commit 5f22cd4
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/race_test.go b/race_test.go
@@ -1,6 +1,7 @@
 package rx_test
 
 import (
+	"context"
 	"math/rand"
 	"testing"
 	"time"
@@ -16,8 +17,9 @@ func TestRace(t *testing.T) {
 
 	detachContext := rx.NewOperator(
 		func(source rx.Observable[string]) rx.Observable[string] {
-			return func(_ rx.Context, o rx.Observer[string]) {
-				source.Subscribe(rx.NewBackgroundContext(), o)
+			return func(c rx.Context, o rx.Observer[string]) {
+				c.Context = context.Background()
+				source.Subscribe(c, o)
 			}
 		},
 	)