import { StreamChunk, GenerateContentResponse } from '../../types';
export interface StreamOptions {
    onChunk?: (chunk: StreamChunk) => void;
    onComplete?: (response: GenerateContentResponse) => void;
    onError?: (error: Error) => void;
    onThinking?: (thinking: string) => void;
}
export declare class StreamProcessor {
    private decoder;
    processStream(response: Response, options?: StreamOptions): Promise<GenerateContentResponse>;
    private parseStreamChunk;
    private hasThinkingContent;
    private extractThinkingContent;
    private aggregateChunk;
    createAsyncGenerator(response: Response): AsyncGenerator<StreamChunk>;
}