test(Stream/raceAll): add "combined sync + async" test

Effect-TS · Jul 4, 2024 · 9e4f134 · 9e4f134
1 parent f2b536e
commit 9e4f134
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/packages/effect/test/Stream/racing.test.ts b/packages/effect/test/Stream/racing.test.ts
@@ -51,4 +51,17 @@ describe("Stream", () => {
       )
       assert.deepStrictEqual(result, [0, 1, 2, 3])
     }))
+
+  it.effect("raceAll combined sync + async", () =>
+    Effect.gen(function*($) {
+      const result = yield* $(
+        Stream.raceAll(
+          Stream.make(0, 1, 2, 3),
+          Stream.fromSchedule(Schedule.spaced("1 second"))
+        ),
+        Stream.runCollect,
+        Effect.map(Chunk.toReadonlyArray)
+      )
+      assert.deepStrictEqual(result, [0, 1, 2, 3])
+    }))
 })