import { Pricing, Session } from '@refinitiv-data/types';
import { AbstractStateManager } from '../../../state';
export declare class StreamingChainImpl extends AbstractStateManager implements Pricing.Chain.Stream {
    private session;
    name: string;
    protected streamingChainEmitter: Pricing.Chain.Stream;
    private params;
    private constituentList;
    private displayTemplate;
    private chainRecordsNames;
    private chainRecordNameToItemStream;
    private chainRecordNameToResolveCallback;
    private chainRecordNameToStatus;
    private chainRecordNameToChainRecord;
    private chainRecordNameToOffset;
    private chainRecordNameToUpdateData;
    private chainRecordNameToError;
    private isDecodingComplete;
    constructor(session: Session, name: string, params?: Pricing.Chain.RequestParams);
    get definition(): Pricing.Chain.Params;
    initialize(): Promise<void>;
    cleanUp(): Promise<void>;
    get isChain(): boolean;
    get constituents(): string[];
    get summaryLinks(): string[];
    onAdd(cb: Pricing.Chain.OnAddCallback): this;
    onRemove(cb: Pricing.Chain.OnRemoveCallback): this;
    onUpdate(cb: Pricing.Chain.OnUpdateCallback): this;
    onComplete(cb: Pricing.Chain.OnCompleteCallback): this;
    onError(cb: Pricing.Chain.OnErrorCallback): this;
    private processRemainingUpdateData;
    private parallelDecode;
    private openItemStreamForChainRecord;
    private processErrors;
    private emitItemStreamError;
    private addItemStreamListeners;
    private validateSessionState;
    private hasChainRecord;
    private onRefresh;
    private onUpdateOMMStream;
    private onStatus;
    private onStateChanged;
    private checkAllChainRecordsClosed;
    private processChainRecord;
    private updateChainRecord;
    private extractConstituents;
    private appendConstituent;
    private updateConstituent;
    private removeConstituent;
    private getNumberOfSummaryLinks;
}