import { BehaviorSubject, Observable, Subscription } from "rxjs"; /** * A fallback if WebSockets doesn't work so we can't use the Watcher on a cluster * lets just poll in the background */ export declare class Poller { protected pollListFactory: () => Observable; private _dataStream; protected subscription: Subscription; protected pollPeriod: number; protected resourceCache: {}; constructor(pollListFactory: () => Observable, _dataStream: BehaviorSubject); readonly dataStream: Observable; /** * Forces recreation of the poller */ recreate(): void; close(): void; protected closeSubscription(): void; protected lazyCreateSubscription(): void; protected onSubscriptionClosed(): void; ngOnDestroy(): void; private onListMessage(list); } export declare function isNewerResource(resource: any, old: any): boolean;