import type { Candle, OHLCVOptions } from '../../types';
import { BaseWebSocket } from '../base.ws';
import type { OKXExchange } from './okx.exchange';
type Data = Record<string, any>;
type MessageHandlers = {
    [channel: string]: (json: Data) => void;
};
type SubscribedTopics = {
    [id: string]: Array<{
        channel: string;
        instId?: string;
        instType?: string;
    }>;
};
export declare class OKXBusinessWebsocket extends BaseWebSocket<OKXExchange> {
    topics: SubscribedTopics;
    messageHandlers: MessageHandlers;
    connectAndSubscribe: () => void;
    onOpen: () => void;
    ping: () => void;
    auth: () => void;
    subscribe: () => void;
    onMessage: ({ data }: MessageEvent) => void;
    handlePongEvent: () => void;
    handleOrderTopic: ({ data: okxOrders }: Record<string, any>) => void;
    listenOHLCV: (opts: OHLCVOptions, callback: (candle: Candle) => void) => () => void;
}
export {};