Function parseSSEResponse

packages/ai-client/src/sse-parser.ts:49–78

(
  response: Response,
  abortSignal?: AbortSignal,
)

 * (e.g., TanStack Start server functions using `toServerSentEventsResponse()`).
 */
export async function* parseSSEResponse(
  response: Response,
  abortSignal?: AbortSignal,
): AsyncGenerator<StreamChunk> {
  if (!response.ok) {
    throw new Error(
      `HTTP error! status: ${response.status} ${response.statusText}`,
    )
  }

  const reader = getResponseStreamReader(response)

  for await (const line of readStreamLines(reader, abortSignal)) {
    const data = parseSseDataLine(line)

    if (data === '[DONE]') {
      console.warn(
        '[@tanstack/ai-client] Received [DONE] sentinel. This is deprecated — upgrade your @tanstack/ai server package. RUN_FINISHED is the stream terminator.',
      )
      continue
    }

    try {
      const parsed: StreamChunk = JSON.parse(data)
      yield parsed
    } catch (parseError) {
      console.warn('Failed to parse SSE chunk:', data)
    }
  }
}