import { Observable } from 'rxjs';
import { Config } from '../../../types';
import { WebsocketData, WebsocketRequest, WebsocketResponse } from './types';
import { WebsocketInsiderBase } from './websocket-insider-base';
export declare class WebsocketInsider extends WebsocketInsiderBase<WebsocketRequest, WebsocketResponse | WebsocketData> {
    private streamTable;
    constructor(config: Config);
    /**
     * handle message
     *
     * @param message
     */
    handleMessage(message: WebsocketResponse | WebsocketData): void;
    subscribe<T>(channel: string | string[]): Observable<WebsocketData<T>>;
    /**
     * Unsubscribe channel
     *
     * @param channel
     */
    unsubscribe(channel: string | string[]): void;
    onDestroy(): void;
    private fetchOrNewStream;
    private delStream;
}