Function waitForRegistrySize

packages/server/test/connections.e2e.test.ts:174–188

(
  r: RunningServer,
  target: number,
  timeoutMs: number,
)

}

async function waitForRegistrySize(
  r: RunningServer,
  target: number,
  timeoutMs: number,
): Promise<void> {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const size = r.services.invokeFunction((a) => a.get(IConnectionRegistry).size());
    if (size === target) return;
    await new Promise((res) => {
      setTimeout(res, 10);
    });
  }
  throw new Error(`registry size ${String(target)} not observed within ${String(timeoutMs)}ms`);
}

describe('GET /api/v1/connections', () => {
  it('returns an empty list when no clients are attached', async () => {