import { ActiveDefinitions } from "@activeledger/activedefinitions";
import { Shared } from "./shared";
import { IVirtualMachine } from "./interfaces/vm.interface";
import { ActiveDSConnect } from "@activeledger/activeoptions";
import { EventEmitter } from "events";
export declare class StreamUpdater {
    private entry;
    private virtualMachine;
    private reference;
    private nodeResponse;
    private db;
    private dbev;
    private emitter;
    private shared;
    private contractId;
    private docs;
    private streams;
    private collisions;
    private refStreams;
    private earlyCommit;
    constructor(entry: ActiveDefinitions.LedgerEntry, virtualMachine: IVirtualMachine, reference: string, nodeResponse: ActiveDefinitions.INodeResponse, db: ActiveDSConnect, dbev: ActiveDSConnect, emitter: EventEmitter, shared: Shared, contractId: string);
    updateStreams(earlyCommit?: Function): Promise<void>;
    private processNoStreams;
    private processStreams;
    private compactTxEntry;
    private handleContractDataStream;
    private buildReferenceStreams;
    static SAVE_RETRY_DELAYS_MS: number[];
    static SAVE_TIMEOUT_S: number;
    private saveDocs;
    private append;
    private detectCollisions;
}
//# sourceMappingURL=streamUpdater.d.ts.map