(value)
| 394 | return internal.ongoingPromise; |
| 395 | }, |
| 396 | return(value) { |
| 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(); |
| 417 | return returnPromise.then(() => ({ value, done: true })); |
| 418 | } |
| 419 | }); |
| 420 | Object.freeze(ReadableStreamAsyncIteratorPrototype); |
| 421 | function createReadableStreamAsyncIterator(stream, preventCancel) { |
nothing calls this directly
no test coverage detected