| 7656 | return e3._strategyHWM - e3._queueTotalSize; |
| 7657 | } |
| 7658 | function dt(e3) { |
| 7659 | const t2 = e3._controlledWritableStream; |
| 7660 | if (!e3._started) return; |
| 7661 | if (void 0 !== t2._inFlightWriteRequest) return; |
| 7662 | if ("erroring" === t2._state) return void tt(t2); |
| 7663 | if (0 === e3._queue.length) return; |
| 7664 | const r3 = e3._queue.peek().value; |
| 7665 | r3 === lt ? function(e4) { |
| 7666 | const t3 = e4._controlledWritableStream; |
| 7667 | (function(e5) { |
| 7668 | e5._inFlightCloseRequest = e5._closeRequest, e5._closeRequest = void 0; |
| 7669 | })(t3), se2(e4); |
| 7670 | const r4 = e4._closeAlgorithm(); |
| 7671 | ut(e4), b6(r4, () => (function(e5) { |
| 7672 | e5._inFlightCloseRequest._resolve(void 0), e5._inFlightCloseRequest = void 0, "erroring" === e5._state && (e5._storedError = void 0, void 0 !== e5._pendingAbortRequest && (e5._pendingAbortRequest._resolve(), e5._pendingAbortRequest = void 0)), e5._state = "closed"; |
| 7673 | const t4 = e5._writer; |
| 7674 | void 0 !== t4 && vt(t4); |
| 7675 | }(t3), null), (e5) => (function(e6, t4) { |
| 7676 | e6._inFlightCloseRequest._reject(t4), e6._inFlightCloseRequest = void 0, void 0 !== e6._pendingAbortRequest && (e6._pendingAbortRequest._reject(t4), e6._pendingAbortRequest = void 0), Ze(e6, t4); |
| 7677 | }(t3, e5), null)); |
| 7678 | }(e3) : function(e4, t3) { |
| 7679 | const r4 = e4._controlledWritableStream; |
| 7680 | !function(e5) { |
| 7681 | e5._inFlightWriteRequest = e5._writeRequests.shift(); |
| 7682 | }(r4); |
| 7683 | b6(e4._writeAlgorithm(t3), () => { |
| 7684 | !function(e5) { |
| 7685 | e5._inFlightWriteRequest._resolve(void 0), e5._inFlightWriteRequest = void 0; |
| 7686 | }(r4); |
| 7687 | const t4 = r4._state; |
| 7688 | if (se2(e4), !rt(r4) && "writable" === t4) { |
| 7689 | const t5 = bt(e4); |
| 7690 | nt(r4, t5); |
| 7691 | } |
| 7692 | return dt(e4), null; |
| 7693 | }, (t4) => ("writable" === r4._state && ut(e4), function(e5, t5) { |
| 7694 | e5._inFlightWriteRequest._reject(t5), e5._inFlightWriteRequest = void 0, Ze(e5, t5); |
| 7695 | }(r4, t4), null)); |
| 7696 | }(e3, r3); |
| 7697 | } |
| 7698 | function ft(e3, t2) { |
| 7699 | "writable" === e3._controlledWritableStream._state && ht(e3, t2); |
| 7700 | } |