import type { AssistantMessageEventStream } from './pi-ai-types.js';
export declare class EventStream<TEvent, TResult> implements AsyncIterable<TEvent> {
    private readonly isComplete;
    private readonly extractResult;
    private readonly queue;
    private readonly waiting;
    private done;
    private readonly finalResultPromise;
    private resolveFinalResult;
    constructor(isComplete: (event: TEvent) => boolean, extractResult: (event: TEvent) => TResult);
    push(event: TEvent): void;
    end(result?: TResult): void;
    [Symbol.asyncIterator](): AsyncIterator<TEvent>;
    result(): Promise<TResult>;
}
export declare function createAssistantMessageEventStream(): AssistantMessageEventStream;
//# sourceMappingURL=event-stream.d.ts.map