import { DashboardDataStreamNotification } from './protocols/DashboardMessageProtocol';
import { EventEmitter } from 'events';
import { WebSocketConnector } from './WebSocketConnector';
export type ObserverDashboardDataStreamEventsMap<T> = {
    close: [];
    newrow: [row: T];
    streamerror: [error: string];
};
export type ObserverDashboardDataStreamConfig = {
    dataStreamId: string;
};
export declare interface ObserverDashboardDataStream<T> {
    on<U extends keyof ObserverDashboardDataStreamEventsMap<T>>(event: U, listener: (...args: ObserverDashboardDataStreamEventsMap<T>[U]) => void): this;
    off<U extends keyof ObserverDashboardDataStreamEventsMap<T>>(event: U, listener: (...args: ObserverDashboardDataStreamEventsMap<T>[U]) => void): this;
    once<U extends keyof ObserverDashboardDataStreamEventsMap<T>>(event: U, listener: (...args: ObserverDashboardDataStreamEventsMap<T>[U]) => void): this;
    emit<U extends keyof ObserverDashboardDataStreamEventsMap<T>>(event: U, ...args: ObserverDashboardDataStreamEventsMap<T>[U]): boolean;
}
export declare class ObserverDashboardDataStream<T> extends EventEmitter {
    readonly config: ObserverDashboardDataStreamConfig;
    private readonly _channel;
    private readonly _sortFn?;
    private _remoteClosed;
    private _closed;
    private _opened;
    private _rows;
    private _reject?;
    constructor(config: ObserverDashboardDataStreamConfig, _channel: WebSocketConnector, _sortFn?: ((a: T, b: T) => number) | undefined);
    get id(): string;
    get rows(): T[];
    get closed(): boolean;
    get opened(): boolean;
    [Symbol.iterator](): IterableIterator<T>;
    close(): void;
    open(): Promise<void>;
    private _request;
    private _notify;
    dispatch(event: DashboardDataStreamNotification['event']): void;
}
//# sourceMappingURL=ObservedDashboardDataStream.d.ts.map