()
| 8239 | return K5(this) ? void 0 === this._ownerReadableStream ? d6(k6("cancel")) : P3(this, e3) : d6(ee2("cancel")); |
| 8240 | } |
| 8241 | read() { |
| 8242 | if (!K5(this)) return d6(ee2("read")); |
| 8243 | if (void 0 === this._ownerReadableStream) return d6(k6("read from")); |
| 8244 | let e3, t2; |
| 8245 | const r3 = u2((r4, o3) => { |
| 8246 | e3 = r4, t2 = o3; |
| 8247 | }); |
| 8248 | return function(e4, t3) { |
| 8249 | const r4 = e4._ownerReadableStream; |
| 8250 | r4._disturbed = true, "closed" === r4._state ? t3._closeSteps() : "errored" === r4._state ? t3._errorSteps(r4._storedError) : r4._readableStreamController[q5](t3); |
| 8251 | }(this, { _chunkSteps: (t3) => e3({ value: t3, done: false }), _closeSteps: () => e3({ value: void 0, done: true }), _errorSteps: (e4) => t2(e4) }), r3; |
| 8252 | } |
| 8253 | releaseLock() { |
| 8254 | if (!K5(this)) throw ee2("releaseLock"); |
| 8255 | void 0 !== this._ownerReadableStream && function(e3) { |
no test coverage detected