Test

tweak test

tweaks

Author: kabiroberai

Tests/ComposableArchitectureTests/CurrentValueRelayTests.swift

@@ -25,5 +25,34 @@
 
       _ = cancellable
     }
+
+    func testConcurrentSendAndReceive() async {
+      nonisolated(unsafe) let subject = CurrentValueRelay(0)
+      let values = LockIsolated<Set<Int>>([])
+      let cancellable = subject.sink { (value: Int) in
+        values.withValue {
+          _ = $0.insert(value)
+        }
+      }
+
+      let receives = Task.detached { @Sendable in
+        for await _ in subject.values {}
+      }
+
+      await withTaskGroup(of: Void.self) { group in
+        for index in 1...1_000 {
+          group.addTask { @Sendable in
+            subject.send(index)
+          }
+        }
+      }
+
+      receives.cancel()
+      _ = await receives.value
+
+      XCTAssertEqual(values.value, Set(Array(0...1_000)))
+
+      _ = cancellable
+    }
   }
 #endif