import { HttpClient } from './httpClient';
import { Logger } from './logger';

export declare class AblySSEChannel {
    private userId;
    private channel;
    private sseBaseUrl;
    private messageHandler;
    private httpClient;
    private isOpen;
    private eventSource;
    private retryInterval;
    private logger;
    constructor(userId: string, channel: string, sseBaseUrl: string, messageHandler: (message: any) => void, httpClient: HttpClient, logger: Logger);
    private refreshTokenRequest;
    private refreshToken;
    private onError;
    private onMessage;
    private onOpen;
    connect(): Promise<void>;
    disconnect(): void;
    open(options?: {
        retryInterval?: number;
        retryCount?: number;
    }): void;
    close(): void;
    isActive(): boolean;
    isConnected(): boolean;
}
export declare function openAblySSEChannel({ userId, channel, callback, httpClient, sseBaseUrl, logger, }: {
    userId: string;
    channel: string;
    callback: (req: object) => void;
    httpClient: HttpClient;
    logger: Logger;
    sseBaseUrl: string;
}): AblySSEChannel;
export declare function closeAblySSEChannel(channel: AblySSEChannel): void;
//# sourceMappingURL=sse.d.ts.map