()
| 205 | it.effect("fromAsyncIterable", () => |
| 206 | Effect.gen(function*() { |
| 207 | async function* asyncIterable() { |
| 208 | yield 1 |
| 209 | yield 2 |
| 210 | yield 3 |
| 211 | } |
| 212 | |
| 213 | const stream = Stream.fromAsyncIterable(asyncIterable(), identity) |
| 214 | const result = yield* (Stream.runCollect(stream)) |