()
| 10929 | return this._ongoingPromise ? transformPromiseWith(this._ongoingPromise, returnSteps, returnSteps) : returnSteps(); |
| 10930 | } |
| 10931 | _nextSteps() { |
| 10932 | if (this._isFinished) { |
| 10933 | return Promise.resolve({ value: void 0, done: true }); |
| 10934 | } |
| 10935 | const reader = this._reader; |
| 10936 | let resolvePromise; |
| 10937 | let rejectPromise; |
| 10938 | const promise = newPromise((resolve, reject) => { |
| 10939 | resolvePromise = resolve; |
| 10940 | rejectPromise = reject; |
| 10941 | }); |
| 10942 | const readRequest = { |
| 10943 | _chunkSteps: (chunk) => { |
| 10944 | this._ongoingPromise = void 0; |
| 10945 | _queueMicrotask(() => resolvePromise({ value: chunk, done: false })); |
| 10946 | }, |
| 10947 | _closeSteps: () => { |
| 10948 | this._ongoingPromise = void 0; |
| 10949 | this._isFinished = true; |
| 10950 | ReadableStreamReaderGenericRelease(reader); |
| 10951 | resolvePromise({ value: void 0, done: true }); |
| 10952 | }, |
| 10953 | _errorSteps: (reason) => { |
| 10954 | this._ongoingPromise = void 0; |
| 10955 | this._isFinished = true; |
| 10956 | ReadableStreamReaderGenericRelease(reader); |
| 10957 | rejectPromise(reason); |
| 10958 | } |
| 10959 | }; |
| 10960 | ReadableStreamDefaultReaderRead(reader, readRequest); |
| 10961 | return promise; |
| 10962 | } |
| 10963 | _returnSteps(value) { |
| 10964 | if (this._isFinished) { |
| 10965 | return Promise.resolve({ value, done: true }); |
no test coverage detected