/** * StreamParser - Transform OpenAI streaming deltas to Anthropic SSE events * * Responsibilities: * - Process streaming deltas (reasoning_content, content, tool_calls) * - Coordinate with accumulator for state tracking * - Detect and handle planning loops * - Generate appropriate Anthropic SSE events */ import type { DeltaAccumulator } from '../delta-accumulator'; import type { SSEEvent, AnthropicSSEEvent } from './types'; export interface StreamParserConfig { verbose?: boolean; debugMode?: boolean; debugLog?: boolean; writeDebugLog?: (type: string, data: unknown) => void; } export declare class StreamParser { private verbose; private debugMode; private debugLog; private responseBuilder; private toolCallHandler; private writeDebugLog; constructor(config?: StreamParserConfig); /** * Transform OpenAI streaming delta to Anthropic events */ transformDelta(openaiEvent: SSEEvent, accumulator: DeltaAccumulator): AnthropicSSEEvent[]; /** * Handle reasoning content delta */ private handleReasoningDelta; /** * Handle content delta */ private handleContentDelta; /** * Handle tool call deltas */ private handleToolCallDeltas; /** * Close thinking block with signature */ private closeThinkingBlock; /** * Force finalization due to loop detection */ private forceFinalization; /** * Finalize streaming and generate closing events */ finalizeDelta(accumulator: DeltaAccumulator): AnthropicSSEEvent[]; /** * Log message if verbose */ private log; } //# sourceMappingURL=stream-parser.d.ts.map