(controller)
| 515 | evaluate: () => |
| 516 | new ReadableStream<number>({ |
| 517 | start(controller) { |
| 518 | controller.error(new Error("boom")) |
| 519 | } |
| 520 | }), |
| 521 | onError: (error) => new Error(`mapped: ${(error as Error).message}`) |
| 522 | }).pipe(Stream.runDrain, Effect.exit) |