| 7391 | return !!r2(e3) && (!!Object.prototype.hasOwnProperty.call(e3, "_associatedReadableByteStreamController") && e3 instanceof ReadableStreamBYOBRequest); |
| 7392 | } |
| 7393 | function be(e3) { |
| 7394 | const t2 = function(e4) { |
| 7395 | const t3 = e4._controlledReadableByteStream; |
| 7396 | if ("readable" !== t3._state) return false; |
| 7397 | if (e4._closeRequested) return false; |
| 7398 | if (!e4._started) return false; |
| 7399 | if (J5(t3) && X4(t3) > 0) return true; |
| 7400 | if (Le(t3) && ze(t3) > 0) return true; |
| 7401 | if (ke(e4) > 0) return true; |
| 7402 | return false; |
| 7403 | }(e3); |
| 7404 | if (!t2) return; |
| 7405 | if (e3._pulling) return void (e3._pullAgain = true); |
| 7406 | e3._pulling = true; |
| 7407 | b6(e3._pullAlgorithm(), () => (e3._pulling = false, e3._pullAgain && (e3._pullAgain = false, be(e3)), null), (t3) => (Pe(e3, t3), null)); |
| 7408 | } |
| 7409 | function he(e3) { |
| 7410 | Re(e3), e3._pendingPullIntos = new S5(); |
| 7411 | } |