Function parseAllSSEChunks

src/__tests__/stream-usage.test.ts:14–19

(body: string)

}

function parseAllSSEChunks(body: string): SSEChunkWithUsage[] {
  return body
    .split("\n\n")
    .filter((line) => line.startsWith("data: ") && !line.includes("[DONE]"))
    .map((line) => JSON.parse(line.slice(6)));
}

function hasUsageChunk(chunks: SSEChunkWithUsage[]): boolean {
  return chunks.some((c) => c.usage !== undefined && c.choices.length === 0);