import { Observable, Subject, ConnectableObservable } from 'rxjs';
import { HttpRequest } from '../../httpClient/HttpRequest';
import { HttpResponse } from '../../httpClient/HttpResponse';
import { IRxHttpClient } from '../../httpClient/IRxHttpClient';
import { IRxWebSocketController } from './IRxWebSocketController';
import { IWebSocketClient } from '../IWebSocketClient';
export declare class RxWebSocketController implements IRxHttpClient, IRxWebSocketController {
    websocketClient: IWebSocketClient;
    url: string;
    protocols: string | string[];
    onMessage: Observable<any>;
    onState: Observable<number>;
    messageSubject: Subject<any>;
    stateSubject: Subject<number>;
    publish: ConnectableObservable<any>;
    constructor(_webSocketClient: IWebSocketClient);
    open(url: string, protocols?: string | string[]): Observable<boolean>;
    send(data: string | ArrayBuffer | Blob): void;
    execute(httpRequest: HttpRequest): Observable<HttpResponse>;
}