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

Function ReadableByteStreamControllerEnqueueClonedChunkToQueue

out/cli.cjs:11422–11431  ·  view source on GitHub ↗
(controller, buffer, byteOffset, byteLength)

Source from the content-addressed store, hash-verified

11420 controller._queueTotalSize += byteLength;
11421 }
11422 function ReadableByteStreamControllerEnqueueClonedChunkToQueue(controller, buffer, byteOffset, byteLength) {
11423 let clonedChunk;
11424 try {
11425 clonedChunk = ArrayBufferSlice(buffer, byteOffset, byteOffset + byteLength);
11426 } catch (cloneE) {
11427 ReadableByteStreamControllerError(controller, cloneE);
11428 throw cloneE;
11429 }
11430 ReadableByteStreamControllerEnqueueChunkToQueue(controller, clonedChunk, 0, byteLength);
11431 }
11432 function ReadableByteStreamControllerEnqueueDetachedPullIntoToQueue(controller, firstDescriptor) {
11433 if (firstDescriptor.bytesFilled > 0) {
11434 ReadableByteStreamControllerEnqueueClonedChunkToQueue(controller, firstDescriptor.buffer, firstDescriptor.byteOffset, firstDescriptor.bytesFilled);

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…