import type { CallOptions } from './rpc-client.js';
export type LiveViewFrame<T> = {
    type: 'snapshot';
    items: T[];
    operationId?: string;
} | {
    type: 'upsert';
    record: T;
    afterId?: string | null;
    operationId?: string;
} | {
    type: 'remove';
    id: string;
    operationId?: string;
} | {
    type: 'heartbeat';
    intervalMs?: number;
};
export type LiveViewStatus = 'connecting' | 'ready' | 'reconnecting' | 'error' | 'closed';
export type LiveViewSnapshot<T> = {
    readonly items: readonly T[];
    readonly status: LiveViewStatus;
    readonly error: unknown;
};
export type LiveViewOptions<T> = {
    subscribe: (options: {
        signal: AbortSignal;
    }) => AsyncIterable<LiveViewFrame<T>> | Promise<AsyncIterable<LiveViewFrame<T>>>;
    getKey?: (record: T) => string;
    createOperationId?: () => string;
    retryMs?: number;
    /** Reconnect after this multiple of the server heartbeat interval is silent. */
    livenessFactor?: number;
    /** Maximum wait after HTTP success for the matching live frame. */
    ackTimeoutMs?: number;
};
export type MutationMethod<TArgs, TResult> = (args: TArgs, options: CallOptions & {
    operationId: string;
}) => Promise<TResult>;
export type LiveView<T> = {
    getSnapshot(): LiveViewSnapshot<T>;
    subscribe(listener: () => void): () => void;
    mutate<TArgs, TResult>(method: MutationMethod<TArgs, TResult>, args: TArgs, options?: Omit<CallOptions, 'operationId'>): Promise<TResult>;
    resync(): void;
    close(): void;
    readonly done: Promise<void>;
};
export declare function createLiveView<T>(options: LiveViewOptions<T>): LiveView<T>;
//# sourceMappingURL=live-view.d.ts.map