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

Function ReadableByteStreamControllerRespondInternal

out/cli.cjs:11592–11602  ·  view source on GitHub ↗
(controller, bytesWritten)

Source from the content-addressed store, hash-verified

11590 ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue(controller);
11591 }
11592 function ReadableByteStreamControllerRespondInternal(controller, bytesWritten) {
11593 const firstDescriptor = controller._pendingPullIntos.peek();
11594 ReadableByteStreamControllerInvalidateBYOBRequest(controller);
11595 const state2 = controller._controlledReadableByteStream._state;
11596 if (state2 === "closed") {
11597 ReadableByteStreamControllerRespondInClosedState(controller, firstDescriptor);
11598 } else {
11599 ReadableByteStreamControllerRespondInReadableState(controller, bytesWritten, firstDescriptor);
11600 }
11601 ReadableByteStreamControllerCallPullIfNeeded(controller);
11602 }
11603 function ReadableByteStreamControllerShiftPendingPullInto(controller) {
11604 const descriptor = controller._pendingPullIntos.shift();
11605 return descriptor;

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…