Function getWorkspaceStreamsForTests

src/node/services/streamManager.test.ts:125–132

(streamManager: StreamManager)

}

function getWorkspaceStreamsForTests(streamManager: StreamManager): Map<string, unknown> {
  const workspaceStreams: unknown = Reflect.get(streamManager, "workspaceStreams");
  expect(workspaceStreams instanceof Map).toBe(true);
  if (!(workspaceStreams instanceof Map)) {
    throw new Error("Expected StreamManager.workspaceStreams to be a Map");
  }
  return workspaceStreams as Map<string, unknown>;
}

async function appendPartialAssistantForTests(
  workspaceId: string,