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

Function ReadableByteStreamControllerRespond

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

Source from the content-addressed store, hash-verified

11729 return controller._strategyHWM - controller._queueTotalSize;
11730 }
11731 function ReadableByteStreamControllerRespond(controller, bytesWritten) {
11732 const firstDescriptor = controller._pendingPullIntos.peek();
11733 const state2 = controller._controlledReadableByteStream._state;
11734 if (state2 === "closed") {
11735 if (bytesWritten !== 0) {
11736 throw new TypeError("bytesWritten must be 0 when calling respond() on a closed stream");
11737 }
11738 } else {
11739 if (bytesWritten === 0) {
11740 throw new TypeError("bytesWritten must be greater than 0 when calling respond() on a readable stream");
11741 }
11742 if (firstDescriptor.bytesFilled + bytesWritten > firstDescriptor.byteLength) {
11743 throw new RangeError("bytesWritten out of range");
11744 }
11745 }
11746 firstDescriptor.buffer = TransferArrayBuffer(firstDescriptor.buffer);
11747 ReadableByteStreamControllerRespondInternal(controller, bytesWritten);
11748 }
11749 function ReadableByteStreamControllerRespondWithNewView(controller, view) {
11750 const firstDescriptor = controller._pendingPullIntos.peek();
11751 const state2 = controller._controlledReadableByteStream._state;

Callers 3

respondMethod · 0.85
pullWithDefaultReaderFunction · 0.85
pullWithBYOBReaderFunction · 0.85

Calls 3

TransferArrayBufferFunction · 0.85
peekMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…