import { IStorage } from './storage';

type TUndeliveredSyncConfig = {
    storage: IStorage;
    storageKey?: string;
    /**
     * Called when a storage read/write fails. Without it the in-memory
     * queue silently stops being durable.
     */
    onPersistError?: (error: unknown) => void;
};
export declare function createUndeliveredSync<T extends {
    id: string;
}>(config: TUndeliveredSyncConfig): {
    init: () => Promise<void>;
    isInitialized(): boolean;
    subscribe(listener: () => void): () => void;
    getChannelMessages(channel: string): T[];
    addMessage(channel: string, msg: T): void;
    removeMessage(channel: string, messageId: string): void;
    setChannelMessages(channel: string, messages: T[]): void;
    clearChannel(channel: string): void;
    clearAll(): void;
};
export type TUndeliveredSync<T extends {
    id: string;
}> = ReturnType<typeof createUndeliveredSync<T>>;
export {};
//# sourceMappingURL=undelivered-sync.d.ts.map