import { type EventDispatcherDeps } from './event-dispatcher.js';
import type { AwbConfig } from './rest.js';
export interface EventStreamOptions {
    config: AwbConfig;
    deps?: EventDispatcherDeps;
    pluginVersion?: string;
    onConnect?: (() => void) | null;
}
export interface SseParseState {
    buffer: string;
    eventType: string;
    currentId: string;
    lastEventId: string;
}
export declare function newSseParseState(lastEventId?: string): SseParseState;
export declare function feedSse(state: SseParseState, chunk: string): Array<{
    eventType: string;
    data: string;
}>;
export declare class EventStream {
    #private;
    constructor(opts: EventStreamOptions);
    start(): void;
    stop(): void;
    wakePoolRetries(reason: string): void;
    recordHarnessSessionLimit(info: {
        agentId: string;
        ticketId?: string;
        role?: string;
        deferUntilMs: number;
        reason?: string;
        resetLabel?: string;
    }): void;
    reconnect(): Promise<void>;
}