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

Function createStreamCollector

tests/ipc/streamCollector.ts:485–490  ·  view source on GitHub ↗
(
  client: OrpcTestClient,
  workspaceId: string
)

Source from the content-addressed store, hash-verified

483 * Remember to call start() before sending messages.
484 */
485export function createStreamCollector(
486 client: OrpcTestClient,
487 workspaceId: string
488): StreamCollector {
489 return new StreamCollector(client, workspaceId);
490}
491
492/**
493 * Assert that a stream completed successfully.

Callers 15

createWorkspaceWithInitFunction · 0.90
sendMessageAndWaitFunction · 0.90
createEventCollectorFunction · 0.90
waitForInitCompleteFunction · 0.90
waitForInitEndFunction · 0.90
init.test.tsFile · 0.90
interrupt.test.tsFile · 0.90
withStreamCollectionFunction · 0.85
waitForStreamSuccessFunction · 0.85
withSharedWorkspaceFunction · 0.85

Calls

no outgoing calls

Tested by 2

setupInitEventCaptureFunction · 0.68
resumeAndWaitForSuccessFunction · 0.68