(directory: string)
| 24 | }) |
| 25 | |
| 26 | const openEventStream = (directory: string) => |
| 27 | Effect.gen(function* () { |
| 28 | const response = yield* requestInDirectory(EventPaths.event, directory) |
| 29 | const reader = yield* Queue.unbounded<Uint8Array>() |
| 30 | yield* response.stream.pipe( |
| 31 | Stream.runForEach((value) => Queue.offer(reader, value)), |
| 32 | Effect.forkScoped, |
| 33 | ) |
| 34 | return { response, reader } |
| 35 | }) |
| 36 | |
| 37 | afterEach(async () => { |
| 38 | await disposeAllInstances() |
no test coverage detected