export declare class ChangesStreamWorker {
    private readonly changesStreamService;
    private readonly config;
    private readonly logger;
    subscribe(): Promise<void>;
}