(e3)
| 8042 | return p3(e3._readableStreamController[T5](r3), t); |
| 8043 | } |
| 8044 | function Xt(e3) { |
| 8045 | e3._state = "closed"; |
| 8046 | const t2 = e3._reader; |
| 8047 | if (void 0 !== t2 && (j3(t2), K5(t2))) { |
| 8048 | const e4 = t2._readRequests; |
| 8049 | t2._readRequests = new S5(), e4.forEach((e5) => { |
| 8050 | e5._closeSteps(); |
| 8051 | }); |
| 8052 | } |
| 8053 | } |
| 8054 | function Jt(e3, t2) { |
| 8055 | e3._state = "errored", e3._storedError = t2; |
| 8056 | const r3 = e3._reader; |