()
| 397 | const internal = ReadableStreamAsyncIteratorBrand.get(this); |
| 398 | const reader = internal.reader; |
| 399 | const returnSteps = () => { |
| 400 | if (internal.isFinished) { |
| 401 | return Promise.resolve({ value, done: true }); |
| 402 | } |
| 403 | internal.isFinished = true; |
| 404 | assert(reader.stream !== undefined); |
| 405 | assert(reader.readRequests.length === 0); |
| 406 | if (internal.preventCancel === false) { |
| 407 | const result = ReadableStreamReaderGenericCancel(reader, value); |
| 408 | ReadableStreamDefaultReaderRelease(reader); |
| 409 | return result; |
| 410 | } |
| 411 | ReadableStreamDefaultReaderRelease(reader); |
| 412 | return Promise.resolve(undefined); |
| 413 | }; |
| 414 | const returnPromise = internal.ongoingPromise |
| 415 | ? internal.ongoingPromise.then(returnSteps, returnSteps) |
| 416 | : returnSteps(); |
no test coverage detected