MCPcopy
hub / github.com/coder/mux / start

Function start

src/node/utils/gatewayStreamNormalization.test.ts:183–188  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

181 async function collectStream(chunks: unknown[]): Promise<unknown[]> {
182 const stream = new ReadableStream({
183 start(controller) {
184 for (const chunk of chunks) {
185 controller.enqueue(chunk);
186 }
187 controller.close();
188 },
189 });
190
191 const result: unknown[] = [];

Callers

nothing calls this directly

Calls 2

enqueueMethod · 0.80
closeMethod · 0.65

Tested by

no test coverage detected