/** * SSE 流解析工具 * * 提供通用的 SSE 流解析能力,供 ChatCompletionsProxy 和 ResponsesProxy 共用。 * 支持 Node.js ReadableStream(fetch response.body)的 SSE 解析。 */ import type { SSECallbacks } from './types'; /** * 解析 SSE 流(适用于 Node.js fetch response.body) * * 使用方法: * ```ts * const response = await fetch(url, options); * const reader = response.body!.getReader(); * await parseSSEStream(reader, callbacks, abortSignal); * ``` */ export declare function parseSSEStream(reader: ReadableStreamDefaultReader, callbacks: SSECallbacks, abortSignal?: AbortSignal): Promise; /** * Chat Completions SSE 流解析器 * * 解析 OpenAI Chat Completions 格式的 SSE 流,处理: * - 文本内容 delta * - 思考/推理内容(reasoning_content) * - 工具调用 delta(按 index 累积) * - Token 用量统计 */ export declare function parseChatCompletionsStream(reader: ReadableStreamDefaultReader, callbacks: SSECallbacks, abortSignal?: AbortSignal): Promise; /** * Responses API SSE 流解析器 * * 解析 OpenAI Responses 格式的 SSE 流,处理: * - response.output_text.delta(文本 delta) * - response.reasoning_text.delta(推理 delta) * - response.function_call_arguments.delta/done(工具调用) * - response.completed(完成事件 + usage) * - response.failed(失败事件) */ export declare function parseResponsesStream(reader: ReadableStreamDefaultReader, callbacks: SSECallbacks, abortSignal?: AbortSignal): Promise; /** SSE 流式 HTTP POST 请求 */ export declare function fetchSSEPost(url: string, body: Record, headers: Record, signal?: AbortSignal): Promise; //# sourceMappingURL=sse-utils.d.ts.map