MCPcopy
hub / github.com/di-sukharev/opencommit / pull

Function pull

out/cli.cjs:48038–48049  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

48036 iterator2 = iterable[Symbol.asyncIterator]();
48037 },
48038 async pull(controller) {
48039 const { done, value } = await iterator2.next();
48040 if (done) {
48041 queueMicrotask(() => {
48042 controller.close();
48043 });
48044 } else {
48045 const buf = Buffer.isBuffer(value) ? value : Buffer.from(value);
48046 controller.enqueue(new Uint8Array(buf));
48047 }
48048 return controller.desiredSize > 0;
48049 },
48050 async cancel(reason) {
48051 await iterator2.return();
48052 }

Callers

nothing calls this directly

Calls 9

readableStreamCloseFunction · 0.85
isErroredFunction · 0.85
pullAlgorithmFunction · 0.85
_onFinishFunction · 0.85
encodeMethod · 0.80
nextMethod · 0.45
closeMethod · 0.45
fromMethod · 0.45
enqueueMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…