(e3, t2)
| 7494 | "readable" === r3._state && (he(e3), ce2(e3), Ee(e3), Jt(r3, t2)); |
| 7495 | } |
| 7496 | function We(e3, t2) { |
| 7497 | const r3 = e3._queue.shift(); |
| 7498 | e3._queueTotalSize -= r3.byteLength, ve(e3); |
| 7499 | const o3 = new Uint8Array(r3.buffer, r3.byteOffset, r3.byteLength); |
| 7500 | t2._chunkSteps(o3); |
| 7501 | } |
| 7502 | function ke(e3) { |
| 7503 | const t2 = e3._controlledReadableByteStream._state; |
| 7504 | return "errored" === t2 ? null : "closed" === t2 ? 0 : e3._strategyHWM - e3._queueTotalSize; |