import { Observable } from 'rxjs';
import { Alarm, AlarmType } from './utils';
import * as i0 from "@angular/core";
export declare class SignalKStream {
    private _connect;
    private _close;
    private _error;
    private _message;
    private ws;
    private _filter;
    private _wsTimeout;
    private _token;
    private _playbackMode;
    onConnect: Observable<any>;
    onClose: Observable<any>;
    onError: Observable<any>;
    onMessage: Observable<any>;
    version: number;
    endpoint: string;
    selfId: string;
    _source: any;
    set source(val: string);
    set authToken(val: string);
    get connectionTimeout(): number;
    set connectionTimeout(val: number);
    get isOpen(): boolean;
    get filter(): string;
    set filter(id: string);
    get playbackMode(): boolean;
    constructor();
    close(): void;
    open(url: string, subscribe?: string, token?: string): void;
    private parseOnMessage;
    sendRequest(value: any): string;
    put(context: string, path: string, value: any): string;
    login(username: string, password: string): string;
    send(data: any): void;
    sendUpdate(context: string, path: Array<any>): void;
    sendUpdate(context: string, path: string, value: any): void;
    subscribe(context: string, path: Array<any>): void;
    subscribe(context: string, path: string, options?: any): void;
    unsubscribe(context?: string, path?: any): void;
    raiseAlarm(context: string, name: string, alarm: Alarm): void;
    raiseAlarm(context: string, type: AlarmType, alarm: Alarm): void;
    clearAlarm(context: string | undefined, name: string): void;
    isSelf(msg: any): boolean;
    isDelta(msg: any): boolean;
    isHello(msg: any): boolean;
    isResponse(msg: any): boolean;
    static ɵfac: i0.ɵɵFactoryDeclaration<SignalKStream, never>;
    static ɵprov: i0.ɵɵInjectableDeclaration<SignalKStream>;
}