@internal
(readRequest)
| 11297 | } |
| 11298 | /** @internal */ |
| 11299 | [PullSteps](readRequest) { |
| 11300 | const stream4 = this._controlledReadableByteStream; |
| 11301 | if (this._queueTotalSize > 0) { |
| 11302 | ReadableByteStreamControllerFillReadRequestFromQueue(this, readRequest); |
| 11303 | return; |
| 11304 | } |
| 11305 | const autoAllocateChunkSize = this._autoAllocateChunkSize; |
| 11306 | if (autoAllocateChunkSize !== void 0) { |
| 11307 | let buffer; |
| 11308 | try { |
| 11309 | buffer = new ArrayBuffer(autoAllocateChunkSize); |
| 11310 | } catch (bufferE) { |
| 11311 | readRequest._errorSteps(bufferE); |
| 11312 | return; |
| 11313 | } |
| 11314 | const pullIntoDescriptor = { |
| 11315 | buffer, |
| 11316 | bufferByteLength: autoAllocateChunkSize, |
| 11317 | byteOffset: 0, |
| 11318 | byteLength: autoAllocateChunkSize, |
| 11319 | bytesFilled: 0, |
| 11320 | minimumFill: 1, |
| 11321 | elementSize: 1, |
| 11322 | viewConstructor: Uint8Array, |
| 11323 | readerType: "default" |
| 11324 | }; |
| 11325 | this._pendingPullIntos.push(pullIntoDescriptor); |
| 11326 | } |
| 11327 | ReadableStreamAddReadRequest(stream4, readRequest); |
| 11328 | ReadableByteStreamControllerCallPullIfNeeded(this); |
| 11329 | } |
| 11330 | /** @internal */ |
| 11331 | [ReleaseSteps]() { |
| 11332 | if (this._pendingPullIntos.length > 0) { |
nothing calls this directly
no test coverage detected