/** event-subscriber (0.2.5 plan 025 Task 1 split). Moved verbatim from agent-session.ts; public surface unchanged behind the barrel. */
import type { AgentEvent, SubscribeOptions } from "../contracts.js";
export declare class EventSubscriber implements AsyncIterable<AgentEvent>, AsyncIterator<AgentEvent> {
    private readonly sessionId;
    private readonly onClose;
    /** Plan 104 T5: run-scoped unless the host opted into `acrossRuns`. */
    readonly acrossRuns: boolean;
    private readonly queue;
    private readonly waiters;
    private readonly maxQueuedEvents;
    private readonly overflow;
    private closed;
    constructor(sessionId: string, options: SubscribeOptions, onClose: () => void);
    [Symbol.asyncIterator](): AsyncIterator<AgentEvent>;
    next(): Promise<IteratorResult<AgentEvent>>;
    return(): Promise<IteratorResult<AgentEvent>>;
    push(event: AgentEvent): void;
    close(): void;
}