agentAssistAiSse

Parse L2 Agent Assist chat SSE (data: JSON delta / domain / done error).

SSE blockdata: {"delta":"Hello"} data: {"delta":" world"}

deltas: Hello | world

error: (none)

Signatures

function parseAgentAssistAiSseDataLine(line: string): AgentAssistAiSseParsed | null
function consumeAgentAssistAiSseBlocks(
  blocks: readonly string[],
  handlers: AgentAssistAiSseHandlers,
): AgentAssistAiSseReadResult | null
function readAgentAssistAiSseStream(
  body: AgentAssistAiSseReadableBody,
  handlers: AgentAssistAiSseHandlers,
  signal?: AbortSignal,
): Promise<AgentAssistAiSseReadResult>

Usage

import {
  consumeAgentAssistAiSseBlocks,
  parseAgentAssistAiSseDataLine,
  readAgentAssistAiSseStream,
} from '@zengchaowu/shared/functions/sse/agentAssistAiSse'

parseAgentAssistAiSseDataLine('data: {"delta":"hello"}')
// { delta: 'hello' }

await readAgentAssistAiSseStream(res.body, { onDelta }, signal)