MCPcopy Create free account
hub / github.com/Moddable-OpenSource/moddable / returnSteps

Function returnSteps

examples/io/streams/modules/streams.js:399–413  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

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();

Callers 1

returnFunction · 0.85

Calls 4

assertFunction · 0.70
resolveMethod · 0.45

Tested by

no test coverage detected