import { BehaviorSubject, Observable, Subscription } from "rxjs";
import { $WebSocket } from "angular2-websocket/angular2-websocket";
import { OnLogin } from "../../shared/onlogin.service";
import { Poller } from "./poller";
import { PollerFactory } from "./poller-factory.service";
export declare class Watcher<L> {
    protected pathFn: () => String;
    protected queryParams: any;
    protected onLogin: OnLogin;
    protected listFactory: () => Observable<L>;
    protected pollerFactory: PollerFactory;
    protected ws: $WebSocket;
    protected serviceUrl: String;
    protected _dataStream: BehaviorSubject<any>;
    protected subscription: Subscription;
    protected retries: number;
    protected connectTime: number;
    protected poller: Poller<L>;
    constructor(pathFn: () => String, queryParams: any, onLogin: OnLogin, listFactory: () => Observable<L>, pollerFactory: PollerFactory);
    readonly dataStream: Observable<any>;
    /**
     * Forces recreation of the web socket
     */
    recreateIfChanged(): void;
    /**
     * Forces recreation of the web socket
     */
    recreate(): void;
    readonly info: string;
    close(): void;
    protected closeWebSocket(): void;
    /**
     * Returns the query string appended to the websocket URL
     */
    protected readonly query: String;
    protected lazyCreateWebSocket(): void;
    protected onWebSocketError(): void;
    protected lazyCreatePoller(): void;
    ngOnDestroy(): void;
}