import { ModelSubscriptionsConfig } from "../api/ReplicationConfig"; import { Client } from "urql"; import { LocalStorage } from "../../storage"; import { Model } from "../../Model"; import { NetworkIndicator } from "../network/NetworkIndicator"; import { ReplicatorSubscriptions } from "./ReplicatorSubscriptions"; import { Filter } from "../.."; export interface SubscriptionReplicatorConfig { config: ModelSubscriptionsConfig; client: Client; networkIndicator: NetworkIndicator; queries: ReplicatorSubscriptions; storage: LocalStorage; model: Model; } /** * Replication engine for delta queris */ export declare class SubscriptionReplicator { private options; private filter; private wsConnected?; private addSubscription?; private updateSubscription?; private deleteSubscription?; constructor(options: SubscriptionReplicatorConfig); start(): Promise; applyFilter(filter: Filter): void; /** * Stop subscriptions from the * server and unsubscribe * */ stop(): void; private subscribeToChanges; }