MCPcopy Index your code
hub / github.com/nodejs/node / pull

Function pull

benchmark/streams/iter-throughput-broadcast.js:77–83  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

75 let remaining = datasize;
76 const rs = new ReadableStream({
77 pull(controller) {
78 if (remaining <= 0) { controller.close(); return; }
79 const size = Math.min(remaining, chunk.length);
80 remaining -= size;
81 controller.enqueue(
82 size === chunk.length ? chunk : chunk.subarray(0, size));
83 },
84 });
85
86 // Chain tee() calls to get numConsumers branches.

Callers

nothing calls this directly

Calls 3

closeMethod · 0.65
minMethod · 0.45
enqueueMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…