import { Session, RDPRequest, RDPResponse, RDPStream, RDPStreamAckCb, RDPStreamAlarmCb, RDPStreamCompleteCb, RDPStreamErrorCb, RDPStreamRequestParams, RDPStreamResponseCb, RDPStreamUpdateCb, StreamConnection, StreamRequestParams } from '@refinitiv-data/types';
import { AbstractItemStream } from './abstract-item-stream';
export declare class RDPStreamImpl extends AbstractItemStream<RDPRequest, RDPResponse> implements RDPStream {
    private params;
    private currentUniverse;
    private itemStreamEventsEmitter;
    constructor(session: Session, params: RDPStreamRequestParams);
    get universe(): string | string[] | object | object[] | undefined;
    onResponse(cb: RDPStreamResponseCb): this;
    onUpdate(cb: RDPStreamUpdateCb): this;
    onAck(cb: RDPStreamAckCb): this;
    onAlarm(cb: RDPStreamAlarmCb): this;
    onError(cb: RDPStreamErrorCb): this;
    onComplete(cb: RDPStreamCompleteCb): this;
    protected getStreamConnection(): Promise<StreamConnection<RDPResponse>>;
    modify(params: RDPStreamRequestParams): Promise<void>;
    protected getRequestParams(): StreamRequestParams;
    protected emitMessage(message: RDPResponse): void;
}