import { Subject } from 'rxjs';
export interface WsEvent {
    type: string;
    data: any;
}
export default class WebSocketObservable extends Subject<WsEvent> {
    private url;
    private ws;
    private reconnectTimeout;
    constructor(url: string);
    readonly connected: WebSocket;
    send(type: any, data?: {}): boolean;
    on(type: string): import("rxjs/internal/Observable").Observable<WsEvent>;
    destroy(): void;
    reconnect(): void;
    private connect;
    private restartTimer;
    private onMessage;
    private onClose;
}