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

Function forwardReaderError

examples/io/streams/modules/streams.js:1099–1110  ·  view source on GitHub ↗
(thisReader)

Source from the content-addressed store, hash-verified

1097 let branch2;
1098 let cancelPromise = createPromise();
1099 function forwardReaderError(thisReader) {
1100 thisReader.closedPromise.promise.catch(r => {
1101 if (thisReader !== reader) {
1102 return;
1103 }
1104 ReadableByteStreamControllerError(branch1.controller, r);
1105 ReadableByteStreamControllerError(branch2.controller, r);
1106 if (canceled1 === false || canceled2 === false) {
1107 resolvePromise(cancelPromise, undefined);
1108 }
1109 });
1110 }
1111 function pullWithDefaultReader() {
1112 if (ReadableStreamBYOBReaderBrand.has(reader.self)) {
1113 assert(reader.readIntoRequests.length === 0);

Callers 3

pullWithDefaultReaderFunction · 0.85
pullWithBYOBReaderFunction · 0.85
ReadableByteStreamTeeFunction · 0.85

Calls 2

resolvePromiseFunction · 0.85

Tested by

no test coverage detected