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

Function ReadableByteStreamControllerRespondInClosedState

out/cli.cjs:11560–11571  ·  view source on GitHub ↗
(controller, firstDescriptor)

Source from the content-addressed store, hash-verified

11558 ReadableByteStreamControllerCallPullIfNeeded(controller);
11559 }
11560 function ReadableByteStreamControllerRespondInClosedState(controller, firstDescriptor) {
11561 if (firstDescriptor.readerType === "none") {
11562 ReadableByteStreamControllerShiftPendingPullInto(controller);
11563 }
11564 const stream4 = controller._controlledReadableByteStream;
11565 if (ReadableStreamHasBYOBReader(stream4)) {
11566 while (ReadableStreamGetNumReadIntoRequests(stream4) > 0) {
11567 const pullIntoDescriptor = ReadableByteStreamControllerShiftPendingPullInto(controller);
11568 ReadableByteStreamControllerCommitPullIntoDescriptor(stream4, pullIntoDescriptor);
11569 }
11570 }
11571 }
11572 function ReadableByteStreamControllerRespondInReadableState(controller, bytesWritten, pullIntoDescriptor) {
11573 ReadableByteStreamControllerFillHeadPullIntoDescriptor(controller, bytesWritten, pullIntoDescriptor);
11574 if (pullIntoDescriptor.readerType === "none") {

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…