import { ProactiveEventService } from '../proactive/service.js';
export type SourceChangePublishResult = {
    published: number;
    skipped: number;
    sources: number;
};
export declare class ConnectedSourceChangePublisher {
    private readonly eventService;
    private readonly intervalMs;
    private timer;
    private running;
    constructor(eventService: ProactiveEventService, intervalMs?: number);
    start(): void;
    stop(): void;
    runNow(): Promise<SourceChangePublishResult>;
    private publishSource;
}