import type { AssistantMessage, AssistantMessageEvent } from "../types";
export declare class EventStream<T, R = T> implements AsyncIterable<T> {
    #private;
    queue: T[];
    waiting: Array<{
        resolve: (value: IteratorResult<T>) => void;
        reject: (err: unknown) => void;
    }>;
    done: boolean;
    /** True once finalResultPromise has been resolved or rejected. */
    resultSettled: boolean;
    finalResultPromise: Promise<R>;
    resolveFinalResult: (result: R) => void;
    rejectFinalResult: (err: unknown) => void;
    isComplete: (event: T) => boolean;
    extractResult: (event: T) => R;
    constructor(isComplete: (event: T) => boolean, extractResult: (event: T) => R);
    push(event: T): void;
    deliver(event: T): void;
    end(result?: R): void;
    endWaiting(): void;
    fail(err: unknown): void;
    [Symbol.asyncIterator](): AsyncIterator<T>;
    result(): Promise<R>;
}
export declare class AssistantMessageEventStream extends EventStream<AssistantMessageEvent, AssistantMessage> {
    constructor();
    push(event: AssistantMessageEvent): void;
    end(result?: AssistantMessage): void;
}