| 8029 | return void 0 !== e3._reader; |
| 8030 | } |
| 8031 | function Gt(e3, r3) { |
| 8032 | if (e3._disturbed = true, "closed" === e3._state) return c3(void 0); |
| 8033 | if ("errored" === e3._state) return d6(e3._storedError); |
| 8034 | Xt(e3); |
| 8035 | const o3 = e3._reader; |
| 8036 | if (void 0 !== o3 && Fe(o3)) { |
| 8037 | const e4 = o3._readIntoRequests; |
| 8038 | o3._readIntoRequests = new S5(), e4.forEach((e5) => { |
| 8039 | e5._closeSteps(void 0); |
| 8040 | }); |
| 8041 | } |
| 8042 | return p3(e3._readableStreamController[T5](r3), t); |
| 8043 | } |
| 8044 | function Xt(e3) { |
| 8045 | e3._state = "closed"; |
| 8046 | const t2 = e3._reader; |