| 7465 | } |
| 7466 | } |
| 7467 | function qe(e3, t2) { |
| 7468 | const r3 = e3._pendingPullIntos.peek(); |
| 7469 | Re(e3); |
| 7470 | "closed" === e3._controlledReadableByteStream._state ? function(e4, t3) { |
| 7471 | "none" === t3.readerType && Ce(e4); |
| 7472 | const r4 = e4._controlledReadableByteStream; |
| 7473 | if (Le(r4)) for (; ze(r4) > 0; ) _e(r4, Ce(e4)); |
| 7474 | }(e3, r3) : function(e4, t3, r4) { |
| 7475 | if (Se(0, t3, r4), "none" === r4.readerType) return ge(e4, r4), void Te(e4); |
| 7476 | if (r4.bytesFilled < r4.elementSize) return; |
| 7477 | Ce(e4); |
| 7478 | const o3 = r4.bytesFilled % r4.elementSize; |
| 7479 | if (o3 > 0) { |
| 7480 | const t4 = r4.byteOffset + r4.bytesFilled; |
| 7481 | ye(e4, r4.buffer, t4 - o3, o3); |
| 7482 | } |
| 7483 | r4.bytesFilled -= o3, _e(e4._controlledReadableByteStream, r4), Te(e4); |
| 7484 | }(e3, t2, r3), be(e3); |
| 7485 | } |
| 7486 | function Ce(e3) { |
| 7487 | return e3._pendingPullIntos.shift(); |
| 7488 | } |