import { Transform } from "stream";
import { ChatCompletionChunk } from "openai/resources";
import { ChatToolCall } from "../types";
export declare class ChatCompletionStream<T> extends Transform {
    constructor();
    _transform(chunk: any, encoding: string, callback: Function): void;
}
export declare class VisionResultStream<T> extends ChatCompletionStream<T> {
    constructor();
}
export declare const streamingResponseHandle: (response: Response, callback: (data: string | null) => void, options?: {
    spliteStr?: string;
    prefixStr?: string;
    endStr?: string;
}) => Promise<void>;
export declare const streamingResponseCut: (stream: ChatCompletionStream<ChatCompletionChunk>, callback: (data: string | null) => Promise<void>, options?: {}) => Promise<void>;
export declare const streamResponseToolCallsFormat: (stream: ChatCompletionStream<ChatCompletionChunk>) => Promise<ChatToolCall[]>;
export declare const streamResponseFormat: (stream: ChatCompletionStream<ChatCompletionChunk>, callbacks?: {
    onData?: (data: any) => void;
    onContent?: (data: string) => void;
    onCut?: (data: string) => void;
    onToolCall?: (data: {
        id: string;
        function: {
            name: string;
            arguments?: Record<string, any>;
        };
    }) => void;
}) => Promise<void>;
export declare const StreamUtils: {
    /**
     * 处理流式响应的函数。
     *
     * 此函数的目的是从流式响应中提取所需的数据或信息。
     * 它通过分析流式响应的特定字段或行为，来实现对数据的处理和解析。
     *
     */
    handle: (response: Response, callback: (data: string | null) => void, options?: {
        spliteStr?: string;
        prefixStr?: string;
        endStr?: string;
    }) => Promise<void>;
    /**
     * 分割流式响应数据。
     *
     * 该函数用于处理流式响应数据的切割操作。通过指定切割逻辑，可以从一个持续的流式响应中提取出感兴趣的片段。
     * 这对于处理大量的实时数据，比如网络传输的音频或视频流，非常有用。
     */
    cut: (stream: ChatCompletionStream<ChatCompletionChunk>, callback: (data: string | null) => Promise<void>, options?: {}) => Promise<void>;
    /**
     * 处理工具调用的格式化函数。
     *
     * 此函数的目的是将工具的调用结果根据特定的格式进行处理和转换，
     * 以便于后续的使用或展示。它接收一个特定格式的工具调用响应，
     * 并返回经过格式化处理的新响应。
     */
    toolCallsFormat: (stream: ChatCompletionStream<ChatCompletionChunk>) => Promise<ChatToolCall[]>;
    /**
     * 处理响应的格式化函数。
     *
     * 此函数的目的是将响应结果根据特定的格式进行处理和转换，
     * 以便于后续的使用或展示。它接收一个特定格式的响应，并返回经过格式化处理的新响应。
     */
    format: (stream: ChatCompletionStream<ChatCompletionChunk>, callbacks?: {
        onData?: (data: any) => void;
        onContent?: (data: string) => void;
        onCut?: (data: string) => void;
        onToolCall?: (data: {
            id: string;
            function: {
                name: string;
                arguments?: Record<string, any>;
            };
        }) => void;
    }) => Promise<void>;
};