MCPcopy Create free account
hub / github.com/cloudflare/computer / pull

Function pull

packages/rpc/src/server.ts:366–370  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

364 const iterator = it[Symbol.asyncIterator]();
365 return new ReadableStream<T>({
366 async pull(controller) {
367 const { value, done } = await iterator.next();
368 if (done) controller.close();
369 else controller.enqueue(value);
370 },
371 async cancel(reason) {
372 if (iterator.return) await iterator.return(reason as undefined);
373 },

Callers

nothing calls this directly

Calls 1

closeMethod · 0.65

Tested by

no test coverage detected