update(Race): minor changes

b97tsk · Oct 7, 2023 · c79d4ec · c79d4ec
1 parent 014b264
commit c79d4ec
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/race.go b/race.go
@@ -34,7 +34,7 @@ func (some observables[T]) Race(ctx context.Context, sink Observer[T]) {
 		subs[i] = NewPair(context.WithCancel(ctx))
 	}
 
-	var race atomic.Value
+	var race atomic.Uint32
 
 	ctxHoisted := waitgroup.Hoist(ctx)
 
@@ -53,7 +53,7 @@ func (some observables[T]) Race(ctx context.Context, sink Observer[T]) {
 					return
 				}
 
-				if race.CompareAndSwap(nil, subs[index].Left()) {
+				if race.CompareAndSwap(0, 1) {
 					for i := range subs {
 						if i != index {
 							subs[i].Right()()

diff --git a/race_test.go b/race_test.go
@@ -32,7 +32,6 @@ func TestRace(t *testing.T) {
 		)
 	}
 
-	rand.Seed(time.Now().UnixNano())
 	rand.Shuffle(len(s), func(i, j int) { s[i], s[j] = s[j], s[i] })
 
 	NewTestSuite[time.Duration](t).Case(
-Original file line number
+Diff line change
@@ Expand Up / @@ -32,7 +32,6 @@ func TestRace(t *testing.T) { @@
     		)
     	}
-    	rand.Seed(time.Now().UnixNano())
     	rand.Shuffle(len(s), func(i, j int) { s[i], s[j] = s[j], s[i] })
     	NewTestSuite[time.Duration](t).Case(
@@ Expand Down @@