MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / ReadableStreamClose

Function ReadableStreamClose

out/cli.cjs:14153–14167  ·  view source on GitHub ↗
(stream4)

Source from the content-addressed store, hash-verified

14151 return transformPromiseWith(sourceCancelPromise, noop2);
14152 }
14153 function ReadableStreamClose(stream4) {
14154 stream4._state = "closed";
14155 const reader = stream4._reader;
14156 if (reader === void 0) {
14157 return;
14158 }
14159 defaultReaderClosedPromiseResolve(reader);
14160 if (IsReadableStreamDefaultReader(reader)) {
14161 const readRequests = reader._readRequests;
14162 reader._readRequests = new SimpleQueue();
14163 readRequests.forEach((readRequest) => {
14164 readRequest._closeSteps();
14165 });
14166 }
14167 }
14168 function ReadableStreamError(stream4, e3) {
14169 stream4._state = "errored";
14170 stream4._storedError = e3;

Calls 3

forEachMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…