(controller)
| 4783 | successSteps(yield readAllBytes(reader)); |
| 4784 | } catch (e) { |
| 4785 | errorSteps(e); |
| 4786 | } |
| 4787 | }); |
| 4788 | } |
| 4789 | function isReadableStreamLike(stream) { |
| 4790 | return stream instanceof ReadableStream || stream[Symbol.toStringTag] === "ReadableStream" && typeof stream.tee === "function"; |
| 4791 | } |
| 4792 | function readableStreamClose(controller) { |
| 4793 | var _a; |
| 4794 | try { |
| 4795 | controller.close(); |
| 4796 | (_a = controller.byobRequest) == null ? void 0 : _a.respond(0); |
| 4797 | } catch (err) { |
| 4798 | if (!err.message.includes("Controller is already closed") && !err.message.includes("ReadableStream is already closed")) { |
no test coverage detected