| 7615 | }(e3) && r3._started && tt(e3); |
| 7616 | } |
| 7617 | function tt(e3) { |
| 7618 | e3._state = "errored", e3._writableStreamController[R6](); |
| 7619 | const t2 = e3._storedError; |
| 7620 | if (e3._writeRequests.forEach((e4) => { |
| 7621 | e4._reject(t2); |
| 7622 | }), e3._writeRequests = new S5(), void 0 === e3._pendingAbortRequest) return void ot(e3); |
| 7623 | const r3 = e3._pendingAbortRequest; |
| 7624 | if (e3._pendingAbortRequest = void 0, r3._wasAlreadyErroring) return r3._reject(t2), void ot(e3); |
| 7625 | b6(e3._writableStreamController[v4](r3._reason), () => (r3._resolve(), ot(e3), null), (t3) => (r3._reject(t3), ot(e3), null)); |
| 7626 | } |
| 7627 | function rt(e3) { |
| 7628 | return void 0 !== e3._closeRequest || void 0 !== e3._inFlightCloseRequest; |
| 7629 | } |