MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / [PullSteps]

Method [PullSteps]

out/cli.cjs:11299–11329  ·  view source on GitHub ↗

@internal

(readRequest)

Source from the content-addressed store, hash-verified

11297 }
11298 /** @internal */
11299 [PullSteps](readRequest) {
11300 const stream4 = this._controlledReadableByteStream;
11301 if (this._queueTotalSize > 0) {
11302 ReadableByteStreamControllerFillReadRequestFromQueue(this, readRequest);
11303 return;
11304 }
11305 const autoAllocateChunkSize = this._autoAllocateChunkSize;
11306 if (autoAllocateChunkSize !== void 0) {
11307 let buffer;
11308 try {
11309 buffer = new ArrayBuffer(autoAllocateChunkSize);
11310 } catch (bufferE) {
11311 readRequest._errorSteps(bufferE);
11312 return;
11313 }
11314 const pullIntoDescriptor = {
11315 buffer,
11316 bufferByteLength: autoAllocateChunkSize,
11317 byteOffset: 0,
11318 byteLength: autoAllocateChunkSize,
11319 bytesFilled: 0,
11320 minimumFill: 1,
11321 elementSize: 1,
11322 viewConstructor: Uint8Array,
11323 readerType: "default"
11324 };
11325 this._pendingPullIntos.push(pullIntoDescriptor);
11326 }
11327 ReadableStreamAddReadRequest(stream4, readRequest);
11328 ReadableByteStreamControllerCallPullIfNeeded(this);
11329 }
11330 /** @internal */
11331 [ReleaseSteps]() {
11332 if (this._pendingPullIntos.length > 0) {

Callers

nothing calls this directly

Tested by

no test coverage detected