Function collectEvents

src/app/service/agent/core/agent.test.ts:73–82

(
  parseFn: typeof parseOpenAIStream,
  chunks: string[],
  signal?: AbortSignal
)

// 辅助函数：收集 parseStream 产生的所有事件
async function collectEvents(
  parseFn: typeof parseOpenAIStream,
  chunks: string[],
  signal?: AbortSignal
): Promise<ChatStreamEvent[]> {
  const events: ChatStreamEvent[] = [];
  const reader = createMockReader(chunks);
  await parseFn(reader, (e) => events.push(e), signal ?? new AbortController().signal);
  return events;
}

describe("SSEParser", () => {
  it("应正确解析单个 SSE 事件", () => {