(controller)
| 592 | const reader = source.getReader() |
| 593 | const body = new ReadableStream<Uint8Array>({ |
| 594 | pull(controller) { |
| 595 | return reader.read().then(({ done, value }) => { |
| 596 | if (done) controller.close() |
| 597 | else controller.enqueue(value) |
| 598 | }) |
| 599 | }, |
| 600 | cancel(reason) { |
| 601 | cancelled = true |
| 602 | return reader.cancel(reason) |