| 9752 | return this[kBody]; |
| 9753 | } |
| 9754 | dump(opts) { |
| 9755 | return __async(this, null, function* () { |
| 9756 | let limit = Number.isFinite(opts == null ? void 0 : opts.limit) ? opts.limit : 128 * 1024; |
| 9757 | const signal = opts == null ? void 0 : opts.signal; |
| 9758 | if (signal != null && (typeof signal !== "object" || !("aborted" in signal))) { |
| 9759 | throw new InvalidArgumentError("signal must be an AbortSignal"); |
| 9760 | } |
| 9761 | signal == null ? void 0 : signal.throwIfAborted(); |
| 9762 | if (this._readableState.closeEmitted) { |
| 9763 | return null; |
| 9764 | } |
| 9765 | return yield new Promise((resolve2, reject) => { |
| 9766 | if (this[kContentLength] > limit) { |
| 9767 | this.destroy(new AbortError()); |
| 9768 | } |
| 9769 | const onAbort = () => { |
| 9770 | var _a; |
| 9771 | this.destroy((_a = signal.reason) != null ? _a : new AbortError()); |
| 9772 | }; |
| 9773 | signal == null ? void 0 : signal.addEventListener("abort", onAbort); |
| 9774 | this.on("close", function() { |
| 9775 | var _a; |
| 9776 | signal == null ? void 0 : signal.removeEventListener("abort", onAbort); |
| 9777 | if (signal == null ? void 0 : signal.aborted) { |
| 9778 | reject((_a = signal.reason) != null ? _a : new AbortError()); |
| 9779 | } else { |
| 9780 | resolve2(null); |
| 9781 | } |
| 9782 | }).on("error", noop).on("data", function(chunk) { |
| 9783 | limit -= chunk.length; |
| 9784 | if (limit <= 0) { |
| 9785 | this.destroy(); |
| 9786 | } |
| 9787 | }).resume(); |
| 9788 | }); |
| 9789 | }); |
| 9790 | } |
| 9791 | }; |
| 9792 | function isLocked(self) { |
| 9793 | return self[kBody] && self[kBody].locked === true || self[kConsume]; |