import { HistoricalPricing, Session } from '@refinitiv-data/types';
import { AbstractStateManager } from '../../../../state';
export declare enum EventTypes {
    Trade = 1,
    Quote = 2,
    Correction = 4
}
export declare class TimeSeriesPricingStream extends AbstractStateManager implements HistoricalPricing.TimeSeries.Stream.Stream<HistoricalPricing.TimeSeries.Stream.PricingType> {
    private readonly stateService;
    session: Session;
    private ruleEngineService;
    private readonly parameters;
    readonly ricStateService: HistoricalPricing.TimeSeries.Services.RicStateService;
    streamEmitter: HistoricalPricing.TimeSeries.Stream.Stream<HistoricalPricing.TimeSeries.Stream.StreamType>;
    private readonly api;
    private pricingStream?;
    private internalState;
    private prevData;
    private prevCummulativeVolume;
    private instrumentMetadata;
    private tradingSessionService;
    private currentUpdate?;
    private readonly dictionariesStream;
    constructor(stateService: HistoricalPricing.TimeSeries.Services.StateService, session: Session, ruleEngineService: HistoricalPricing.TimeSeries.Services.RuleEngineService, parameters: HistoricalPricing.TimeSeries.Params, ricStateService: HistoricalPricing.TimeSeries.Services.RicStateService);
    get definition(): HistoricalPricing.TimeSeries.Params;
    initialize(): Promise<void>;
    private openItemStream;
    private addPricingInstrumentListeners;
    private onSingleStreamRefresh;
    private onSingleStreamUpdate;
    private getRecordsFromUpdate;
    private addQualifierFields;
    private createQualifierDisplayValue;
    private onSingleStreamError;
    private onSingleStreamStatus;
    private onSingleStreamStateChanged;
    private checkAllPricingStreamClosed;
    cleanUp(): Promise<void>;
    onRefresh(cb: HistoricalPricing.TimeSeries.Stream.StreamRefreshCallback): this;
    onUpdate(cb: HistoricalPricing.TimeSeries.Stream.StreamUpdateCallback): this;
    onStatus(cb: HistoricalPricing.TimeSeries.Stream.StreamStatusCallback): this;
    onComplete(cb: HistoricalPricing.TimeSeries.Stream.StreamCompleteCallback): this;
    onError(cb: HistoricalPricing.TimeSeries.Stream.StreamErrorCallback): this;
    onInsert(cb: HistoricalPricing.TimeSeries.Stream.StreamInsertCallback<HistoricalPricing.TimeSeries.Stream.PricingType>): this;
}