import { Observable, Subscription } from 'rxjs';
import { PubsubMessage } from './pubsub-message.js';
import { ObservableWithNext } from './observable-with-next.js';
export declare class PubsubKeepalive extends Observable<PubsubMessage> implements ObservableWithNext<PubsubMessage> {
    private readonly pubsub;
    private readonly maxPubsubPublishInterval;
    private readonly maxIntervalWithoutKeepalive;
    private lastPublishedMessageDate;
    private lastPublishedKeepAliveMessageDate;
    constructor(pubsub: ObservableWithNext<PubsubMessage>, maxPubsubPublishInterval: number, maxIntervalWithoutKeepalive: number);
    next(message: PubsubMessage): Subscription;
    publishPubsubKeepaliveIfNeeded(): void;
}
//# sourceMappingURL=pubsub-keepalive.d.ts.map