Function waitForStreamSuccess

tests/ipc/streamCollector.ts:567–577

(
  client: OrpcTestClient,
  workspaceId: string,
  timeoutMs: number = 30000
)

 * Common pattern: create collector, wait for end, assert success.
 */
export async function waitForStreamSuccess(
  client: OrpcTestClient,
  workspaceId: string,
  timeoutMs: number = 30000
): Promise<StreamCollector> {
  const collector = createStreamCollector(client, workspaceId);
  collector.start();
  await collector.waitForEvent("stream-end", timeoutMs);
  assertStreamSuccess(collector);
  return collector;
}

/**
 * Extract text content from stream events.