import { ClientDuplexStream } from "@grpc/grpc-js";
import { TransactionClient, TransactionReq, TransactionServer } from "typedb-protocol/proto/transaction";
export declare class BatchDispatcher {
    private static BATCH_WINDOW_SMALL_MILLIS;
    private static BATCH_WINDOW_LARGE_MILLIS;
    private readonly _transmitter;
    private readonly _transactionStream;
    private _bufferedRequests;
    private _isRunning;
    constructor(transmitter: RequestTransmitter, transactionStream: ClientDuplexStream<TransactionClient, TransactionServer>);
    dispatch(req: TransactionReq): void;
    dispatchNow(req: TransactionReq): void;
    close(): void;
    private sendNow;
    private sendScheduledBatch;
    private setSchedule;
}
export declare class RequestTransmitter {
    readonly _dispatchers: Set<BatchDispatcher>;
    private _isOpen;
    constructor();
    close(): void;
    dispatcher(transactionStream: ClientDuplexStream<TransactionClient, TransactionServer>): BatchDispatcher;
}