import { Worker } from "../../contracts";
import { StreamReader } from "../../filesystem";
export declare class ReadProcessor {
    private isBlock;
    private streamReader;
    private onItem;
    private onWait?;
    private onResume?;
    private nextField?;
    private nextValue?;
    private nextCount?;
    private callOnMessage;
    private count;
    private transactionsCount;
    private height;
    private isRunning;
    constructor(isBlock: boolean, streamReader: StreamReader, onItem: Function, onWait?: Function | undefined, onResume?: Function | undefined);
    sync(data: Worker.WorkerSyncData): void;
    start(): Promise<void>;
    private emitCount;
    private waitOrContinue;
    private waitOrContinueCount;
    private waitForSynchronization;
    private emitSynchronized;
}
//# sourceMappingURL=read-processor.d.ts.map