(chunk: Chunk.Chunk<Uint8Array | string | CloseEvent>)
| 200 | const writeScope = yield* Scope.fork(scope, ExecutionStrategy.sequential) |
| 201 | const write = yield* Scope.extend(self.writer, writeScope) |
| 202 | function* emit(chunk: Chunk.Chunk<Uint8Array | string | CloseEvent>) { |
| 203 | for (const data of chunk) { |
| 204 | yield* write(data) |
| 205 | } |
| 206 | } |
| 207 | const input: AsyncProducer.AsyncInputProducer<IE, Chunk.Chunk<Uint8Array | string | CloseEvent>, unknown> = { |
| 208 | awaitRead: () => Effect.void, |
| 209 | emit(chunk) { |