import type { SessionOutboundMessage } from "@getpaseo/protocol/messages";
export type SubscriptionSnapshot<T> = T & {
    subscriptionId: string;
};
export interface SubscriptionObserver<T> {
    snapshot(snapshot: T): void;
    update(message: SessionOutboundMessage): void;
    error?(error: unknown): void;
}
/** A stable local lifetime. IDs change on reconnect; legacy IDs identify local listeners only. */
export interface OwnedSubscription<T> {
    readonly subscriptionId: string | null;
    readonly ready: Promise<SubscriptionSnapshot<T>>;
    subscribe(observer: SubscriptionObserver<SubscriptionSnapshot<T>>): () => void;
    release(): Promise<void>;
}
export interface OwnedSubscriptionsHost {
    release(subscriptionId: string): Promise<void>;
    failed(error: unknown): void;
}
/** Transport routing and lifetime only; query semantics remain with each domain. */
export declare class OwnedSubscriptions {
    private readonly host;
    private readonly registrations;
    private readonly routes;
    private generation;
    private connected;
    constructor(host: OwnedSubscriptionsHost);
    observe<T>(request: (accept: (snapshot: T) => void) => Promise<T>, signal?: AbortSignal, requestFailed?: () => void): OwnedSubscription<T>;
    owns(message: SessionOutboundMessage): boolean;
    receive(message: SessionOutboundMessage): void;
    restore(): void;
    disconnected(): void;
    close(): Promise<void>;
}
//# sourceMappingURL=owned.d.ts.map