import { NatsConnection, QueuedIterator } from '@nats-io/nats-core';
import { Kvm, KvWatchEntry, KvWatchOptions } from '@nats-io/kv';
import { Pair } from '../utils';
import { SubscriptionSyncResult } from './subscriptions';
export declare class KvSubscriptionKey extends Pair<string, string> {
}
export type KvSubscriptionConfig = {
    bucket: string;
    key: string;
    callback: (data: any) => void;
    opts?: KvWatchOptions;
    replayOnReconnect?: boolean;
    onDownloadBytes?: (bytes: number) => void;
};
export declare const kvConsolidateState: import("xstate").PromiseActorLogic<SubscriptionSyncResult<QueuedIterator<KvWatchEntry>>, {
    kvm: Kvm | null;
    connection: NatsConnection | null;
    currentState: Map<string, QueuedIterator<KvWatchEntry>>;
    targetState: Map<string, KvSubscriptionConfig>;
}, import("xstate").EventObject>;
//# sourceMappingURL=kv.d.ts.map