| 7942 | return !!r2(e3) && (!!Object.prototype.hasOwnProperty.call(e3, "_controlledReadableStream") && e3 instanceof ReadableStreamDefaultController); |
| 7943 | } |
| 7944 | function At(e3) { |
| 7945 | const t2 = function(e4) { |
| 7946 | const t3 = e4._controlledReadableStream; |
| 7947 | if (!Ft(e4)) return false; |
| 7948 | if (!e4._started) return false; |
| 7949 | if (Ut(t3) && X4(t3) > 0) return true; |
| 7950 | if (Lt(e4) > 0) return true; |
| 7951 | return false; |
| 7952 | }(e3); |
| 7953 | if (!t2) return; |
| 7954 | if (e3._pulling) return void (e3._pullAgain = true); |
| 7955 | e3._pulling = true; |
| 7956 | b6(e3._pullAlgorithm(), () => (e3._pulling = false, e3._pullAgain && (e3._pullAgain = false, At(e3)), null), (t3) => (zt(e3, t3), null)); |
| 7957 | } |
| 7958 | function jt(e3) { |
| 7959 | e3._pullAlgorithm = void 0, e3._cancelAlgorithm = void 0, e3._strategySizeAlgorithm = void 0; |
| 7960 | } |