| 7579 | return void 0 !== e3._writer; |
| 7580 | } |
| 7581 | function Je(e3, t2) { |
| 7582 | var r3; |
| 7583 | if ("closed" === e3._state || "errored" === e3._state) return c3(void 0); |
| 7584 | e3._writableStreamController._abortReason = t2, null === (r3 = e3._writableStreamController._abortController) || void 0 === r3 || r3.abort(t2); |
| 7585 | const o3 = e3._state; |
| 7586 | if ("closed" === o3 || "errored" === o3) return c3(void 0); |
| 7587 | if (void 0 !== e3._pendingAbortRequest) return e3._pendingAbortRequest._promise; |
| 7588 | let n2 = false; |
| 7589 | "erroring" === o3 && (n2 = true, t2 = void 0); |
| 7590 | const a4 = u2((r4, o4) => { |
| 7591 | e3._pendingAbortRequest = { _promise: void 0, _resolve: r4, _reject: o4, _reason: t2, _wasAlreadyErroring: n2 }; |
| 7592 | }); |
| 7593 | return e3._pendingAbortRequest._promise = a4, n2 || et(e3, t2), a4; |
| 7594 | } |
| 7595 | function Ke(e3) { |
| 7596 | const t2 = e3._state; |
| 7597 | if ("closed" === t2 || "errored" === t2) return d6(new TypeError(`The stream (in ${t2} state) is not in the writable state and cannot be closed`)); |