| 7970 | return !e3._closeRequested && "readable" === e3._controlledReadableStream._state; |
| 7971 | } |
| 7972 | function It(e3, t2, r3, o3) { |
| 7973 | const n2 = Object.create(ReadableStreamDefaultController.prototype); |
| 7974 | let a4, i3, l3; |
| 7975 | a4 = void 0 !== t2.start ? () => t2.start(n2) : () => { |
| 7976 | }, i3 = void 0 !== t2.pull ? () => t2.pull(n2) : () => c3(void 0), l3 = void 0 !== t2.cancel ? (e4) => t2.cancel(e4) : () => c3(void 0), function(e4, t3, r4, o4, n3, a5, i4) { |
| 7977 | t3._controlledReadableStream = e4, t3._queue = void 0, t3._queueTotalSize = void 0, ce2(t3), t3._started = false, t3._closeRequested = false, t3._pullAgain = false, t3._pulling = false, t3._strategySizeAlgorithm = i4, t3._strategyHWM = a5, t3._pullAlgorithm = o4, t3._cancelAlgorithm = n3, e4._readableStreamController = t3, b6(c3(r4()), () => (t3._started = true, At(t3), null), (e5) => (zt(t3, e5), null)); |
| 7978 | }(e3, n2, a4, i3, l3, r3, o3); |
| 7979 | } |
| 7980 | function Dt(e3) { |
| 7981 | return new TypeError(`ReadableStreamDefaultController.prototype.${e3} can only be used on a ReadableStreamDefaultController`); |
| 7982 | } |