/** * SSE 事件接口 */ export interface SSEEvent { event?: string; data?: any; id?: string; } /** * SSE 事件流解析器 */ export declare class SSEParser { private eventBuffer; private currentEvent; private logger; onMessage?: (msg: SSEEvent) => void; /** * 解析SSE数据块 */ parse(chunk: string): void; /** * 处理SSE行数据 */ private processSSELine; /** * 发送当前事件 */ private emitCurrentEvent; /** * 重置解析器状态 */ reset(): void; /** * 获取当前缓冲区大小 */ getBufferSize(): number; /** * 获取当前事件状态 */ getCurrentEvent(): { event?: string; data?: string; id?: string; }; /** * 检查是否有未完成的事件 */ hasIncompleteEvent(): boolean; }