import { OMMFieldValue, OMMFields, OMMResponseState, HistoricalPricing, Session } from '@refinitiv-data/types'; import { AbstractStateManager } from '../../../../state'; export declare class TimeSeriesFacadeStream extends AbstractStateManager implements HistoricalPricing.TimeSeries.Stream.Stream { private readonly type; private readonly pricingStream; private readonly stateService; private readonly externalParameters; private blendingService; session: Session; streamRecordsResolver: HistoricalPricing.TimeSeries.Services.StreamRecordsResolver; private filterUpdatesService; streamEmitter: HistoricalPricing.TimeSeries.Stream.Stream; private readonly dataStrategyProvider; private fields; private mostRecentValues; private isBlendRetry; private readonly parameters; private onBlendingRetryTimeout?; constructor(type: HistoricalPricing.TimeSeries.TimeSeriesType, pricingStream: HistoricalPricing.TimeSeries.Stream.Stream, stateService: HistoricalPricing.TimeSeries.Services.StateService, externalParameters: HistoricalPricing.TimeSeries.Params, blendingService: HistoricalPricing.TimeSeries.Blending.BlendingService, session: Session, streamRecordsResolver: HistoricalPricing.TimeSeries.Services.StreamRecordsResolver, filterUpdatesService: HistoricalPricing.TimeSeries.Services.FilterUpdatesServicePipe); private addPricingStreamListeners; get definition(): HistoricalPricing.TimeSeries.Params; open(): Promise; private onBlendRetry; private onBlendComplete; private sendBlendRetryData; private filterRequestedFields; initialize(): Promise; private createFieldsMapping; protected cleanUp(): Promise; getFieldValue(instrument: string, field: string): OMMFieldValue | undefined; getFields(instrument: string, fields?: string[]): OMMFields | undefined; getItemStatus(instrument: string): OMMResponseState | undefined; onRefresh(cb: HistoricalPricing.TimeSeries.Stream.StreamRefreshCallback): this; onInsert(cb: HistoricalPricing.TimeSeries.Stream.StreamInsertCallback): this; onStatus(cb: HistoricalPricing.TimeSeries.Stream.StreamStatusCallback): this; onComplete(cb: HistoricalPricing.TimeSeries.Stream.StreamCompleteCallback): this; onError(cb: HistoricalPricing.TimeSeries.Stream.StreamErrorCallback): this; onUpdate(cb: HistoricalPricing.TimeSeries.Stream.StreamUpdateCallback): this; private onPricingStreamInsert; private onPricingStreamError; private onPricingStreamComplete; private onPricingStreamStatus; private onPricingStreamRefresh; }