type Schema = {
    [key: string]: any;
};
/**
 * 通用流式解析器
 */
export declare class StreamParser {
    private schema;
    private schemaKeys;
    private parser;
    private textBuffer;
    private lastParsed;
    private streamStates;
    constructor(schema: Schema);
    /**
     * 为指定的顶层键创建一个可读流
     * @param key 必须是 schema 中定义的顶层键之一
     */
    stream<T = any>(key: string): ReadableStream<T>;
    processText(text: string, final: boolean): void;
    /**
     * 处理输入的字符串流，并根据 schema 将数据推送到对应的子流中
     */
    process(stream: AsyncGenerator<string>): Promise<void>;
    private processParsedData;
    private processObject;
    private processArray;
    private processPrimitive;
    /**
     * flush 并关闭一个指定的流
     * 这个方法会发送该键下所有尚未被推送的、已解析的数据
     */
    private completeStream;
    private finalize;
}
export {};