import { AgentExecutionEvent, IExecutionEventBus } from "../event/event_bus";
export declare class ExecutionEventQueue {
    private readonly eventBus;
    private readonly contextId;
    private eventQueue;
    private resolvePromise?;
    private stopped;
    constructor(eventBus: IExecutionEventBus, contextId: string);
    private boundHandleEvent;
    private handleEvent;
    /**
     * Async generator that yields events for this contextId,
     * and auto-stops when a 'message' or final 'status-update' arrives.
     */
    events(): AsyncGenerator<AgentExecutionEvent, void, undefined>;
    stop(): void;
}
//# sourceMappingURL=queue.d.ts.map