( client: OrpcTestClient, workspaceId: string )
| 483 | * Remember to call start() before sending messages. |
| 484 | */ |
| 485 | export 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. |
no outgoing calls