| 7749 | void 0 !== e3._readyPromise_resolve && (e3._readyPromise_resolve(void 0), e3._readyPromise_resolve = void 0, e3._readyPromise_reject = void 0, e3._readyPromiseState = "fulfilled"); |
| 7750 | } |
| 7751 | function kt(e3, t2, r3, o3, n2, a4) { |
| 7752 | const i3 = e3.getReader(), l3 = t2.getWriter(); |
| 7753 | Vt(e3) && (e3._disturbed = true); |
| 7754 | let s2, _7, g5, w7 = false, S6 = false, v5 = "readable", R7 = "writable", T6 = false, q6 = false; |
| 7755 | const C5 = u2((e4) => { |
| 7756 | g5 = e4; |
| 7757 | }); |
| 7758 | let E4 = Promise.resolve(void 0); |
| 7759 | return u2((P4, W6) => { |
| 7760 | let k7; |
| 7761 | function O5() { |
| 7762 | if (w7) return; |
| 7763 | const e4 = u2((e5, t3) => { |
| 7764 | !function r4(o4) { |
| 7765 | o4 ? e5() : f3(function() { |
| 7766 | if (w7) return c3(true); |
| 7767 | return f3(l3.ready, () => f3(i3.read(), (e6) => !!e6.done || (E4 = l3.write(e6.value), m4(E4), false))); |
| 7768 | }(), r4, t3); |
| 7769 | }(false); |
| 7770 | }); |
| 7771 | m4(e4); |
| 7772 | } |
| 7773 | function B3() { |
| 7774 | return v5 = "closed", r3 ? L7() : z6(() => (Ge(t2) && (T6 = rt(t2), R7 = t2._state), T6 || "closed" === R7 ? c3(void 0) : "erroring" === R7 || "errored" === R7 ? d6(_7) : (T6 = true, l3.close())), false, void 0), null; |
| 7775 | } |
| 7776 | function A5(e4) { |
| 7777 | return w7 || (v5 = "errored", s2 = e4, o3 ? L7(true, e4) : z6(() => l3.abort(e4), true, e4)), null; |
| 7778 | } |
| 7779 | function j4(e4) { |
| 7780 | return S6 || (R7 = "errored", _7 = e4, n2 ? L7(true, e4) : z6(() => i3.cancel(e4), true, e4)), null; |
| 7781 | } |
| 7782 | if (void 0 !== a4 && (k7 = () => { |
| 7783 | const e4 = void 0 !== a4.reason ? a4.reason : new Wt("Aborted", "AbortError"), t3 = []; |
| 7784 | o3 || t3.push(() => "writable" === R7 ? l3.abort(e4) : c3(void 0)), n2 || t3.push(() => "readable" === v5 ? i3.cancel(e4) : c3(void 0)), z6(() => Promise.all(t3.map((e5) => e5())), true, e4); |
| 7785 | }, a4.aborted ? k7() : a4.addEventListener("abort", k7)), Vt(e3) && (v5 = e3._state, s2 = e3._storedError), Ge(t2) && (R7 = t2._state, _7 = t2._storedError, T6 = rt(t2)), Vt(e3) && Ge(t2) && (q6 = true, g5()), "errored" === v5) A5(s2); |
| 7786 | else if ("erroring" === R7 || "errored" === R7) j4(_7); |
| 7787 | else if ("closed" === v5) B3(); |
| 7788 | else if (T6 || "closed" === R7) { |
| 7789 | const e4 = new TypeError("the destination writable stream closed before all data could be piped to it"); |
| 7790 | n2 ? L7(true, e4) : z6(() => i3.cancel(e4), true, e4); |
| 7791 | } |
| 7792 | function z6(e4, t3, r4) { |
| 7793 | function o4() { |
| 7794 | return "writable" !== R7 || T6 ? n3() : h3(function() { |
| 7795 | let e5; |
| 7796 | return c3(function t4() { |
| 7797 | if (e5 !== E4) return e5 = E4, p3(E4, t4, t4); |
| 7798 | }()); |
| 7799 | }(), n3), null; |
| 7800 | } |
| 7801 | function n3() { |
| 7802 | return e4 ? b6(e4(), () => F5(t3, r4), (e5) => F5(true, e5)) : F5(t3, r4), null; |
| 7803 | } |
| 7804 | w7 || (w7 = true, q6 ? o4() : h3(C5, o4)); |
| 7805 | } |
| 7806 | function L7(e4, t3) { |
| 7807 | z6(void 0, e4, t3); |
| 7808 | } |