export type SseNotificationEvent = {
    type: string;
    notificationUuid?: string;
};
export type SseListenerStatus = "connected" | "disconnected" | "reconnecting";
type ChorusSseListenerOptions = {
    onConnect?: () => Promise<void>;
    onReconnect?: () => Promise<void>;
    onStatusChange?: (status: SseListenerStatus, error?: string) => Promise<void> | void;
    initialReconnectDelayMs?: number;
    maxReconnectDelayMs?: number;
};
export type ParsedSseNotificationChunk = {
    events: SseNotificationEvent[];
    buffer: string;
};
export declare function parseSseNotificationChunk(buffer: string, chunk: string): ParsedSseNotificationChunk;
export declare class ChorusSseListener {
    private readonly chorusUrl;
    private readonly apiKey;
    private readonly onEvent;
    private readonly options;
    private abortController;
    private statusValue;
    private connectPromise;
    private reconnectDelayTimer;
    private reconnectDelayResolve;
    private stopped;
    constructor(chorusUrl: string, apiKey: string, onEvent: (event: SseNotificationEvent) => void, options?: ChorusSseListenerOptions);
    get status(): SseListenerStatus;
    connect(): Promise<void>;
    disconnect(): void;
    private run;
    private consume;
    private updateStatus;
    private waitForReconnectDelay;
    private cancelReconnectDelay;
}
export {};