(stream: InputTransformStream)
| 646 | |
| 647 | const writers = new WeakMap<InputTransformStream, WritableStreamDefaultWriter<Uint8Array>>() |
| 648 | const getWriter = (stream: InputTransformStream) => { |
| 649 | let writer = writers.get(stream) |
| 650 | if (!writer) { |
| 651 | writer = stream.writable.getWriter() |
| 652 | writers.set(stream, writer) |
| 653 | } |
| 654 | return writer |
| 655 | } |
| 656 | const write = (chunk: Uint8Array | string | CloseEvent) => |
| 657 | latch.whenOpen(Effect.suspend(() => { |
| 658 | const { fiberSet, stream } = currentStream! |