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

Function ReadableStreamDefaultReaderRead

out/cli.cjs:10887–10897  ·  view source on GitHub ↗
(reader, readRequest)

Source from the content-addressed store, hash-verified

10885 return x5 instanceof ReadableStreamDefaultReader2;
10886 }
10887 function ReadableStreamDefaultReaderRead(reader, readRequest) {
10888 const stream4 = reader._ownerReadableStream;
10889 stream4._disturbed = true;
10890 if (stream4._state === "closed") {
10891 readRequest._closeSteps();
10892 } else if (stream4._state === "errored") {
10893 readRequest._errorSteps(stream4._storedError);
10894 } else {
10895 stream4._readableStreamController[PullSteps](readRequest);
10896 }
10897 }
10898 function ReadableStreamDefaultReaderRelease(reader) {
10899 ReadableStreamReaderGenericRelease(reader);
10900 const e3 = new TypeError("Reader was released");

Callers 5

readMethod · 0.85
_nextStepsMethod · 0.85
pipeStepFunction · 0.85
pullAlgorithmFunction · 0.85
pullWithDefaultReaderFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…