import type { RealtimeNotifier, SyncRequestContext } from './context.js';
import type { RemoteOperationRegistry } from './operations.js';
import type { StoredCommit } from './storage.js';
export interface RemoteOperationWatchSession {
    receive(bytes: Uint8Array): Promise<void>;
    close(): void;
}
/** In-memory invalidation hub. Every notification reruns affected watches. */
export declare class RemoteOperationWatchHub implements RealtimeNotifier {
    #private;
    constructor(registry: RemoteOperationRegistry);
    connect(ctx: SyncRequestContext, send: (bytes: Uint8Array) => void): RemoteOperationWatchSession;
    notifyCommit(partition: string, commit: StoredCommit): void;
}
/** Fan one applied commit into sync deltas and registered query watches. */
export declare function composeRealtimeNotifiers(...notifiers: readonly RealtimeNotifier[]): RealtimeNotifier;