import { OnDestroy } from "@angular/core";
import { Observable, Subject, Subscriber, Subscription } from "rxjs";
import { NamespacedResourceService } from "../service/namespaced.resource.service";
import { KubernetesResource } from "../model/kubernetesresource.model";
import { Services } from "../model/service.model";
import { RouteService } from "../service/route.service";
import { ServiceService } from "../service/service.service";
import { Watcher } from "../service/watcher";
import { DeploymentService } from "../service/deployment.service";
import { DeploymentConfigService } from "../service/deploymentconfig.service";
import { DeploymentViews } from "../view/deployment.view";
import { Deployments } from "../model/deployment.model";
import { ReplicationControllerService } from "../service/replicationcontroller.service";
import { ReplicaSetViews } from "../view/replicaset.view";
import { ReplicaSetService } from "../service/replicaset.service";
/**
 * A base class for components which watch kubernetes resources which contains a number of helper functions
 * for watching various kinds of resources in kubernetes together with logic to help close up watches after the
 * component has been used
 */
export declare class AbstractWatchComponent implements OnDestroy {
    subjectCache: Map<string, Subject<any[]>>;
    private watchCache;
    ngOnDestroy(): void;
    protected listAndWatchServices(namespace: string, serviceService: ServiceService, routeService: RouteService): Observable<Services>;
    listAndWatchCombinedDeployments(namespace: string, deploymentService: DeploymentService, deploymentConfigService: DeploymentConfigService): Observable<Deployments>;
    listAndWatchDeployments(namespace: string, deploymentService: DeploymentService, deploymentConfigService: DeploymentConfigService, serviceService: ServiceService, routeService: RouteService): Observable<DeploymentViews>;
    listAndWatchReplicas(namespace: string, replicaSetService: ReplicaSetService, replicationControllerService: ReplicationControllerService, serviceService: ServiceService, routeService: RouteService): Observable<ReplicaSetViews>;
    protected listAndWatch<T extends KubernetesResource, L extends Array<T>>(service: NamespacedResourceService<T, L>, namespace: string, type: {
        new (): T;
    }): Observable<L>;
    protected getOrCreateSubject<T extends KubernetesResource, L extends Array<T>>(key: string, createObserverFn: () => Observable<L>): Observable<L>;
    protected getOrCreateWatch<T extends KubernetesResource, L extends Array<T>>(service: NamespacedResourceService<T, L>, namespace: string, type: {
        new (): T;
    }): Watcher<L>;
    /**
     * Lets combine the web socket events with the latest list
     */
    protected combineListAndWatchEvent<T extends KubernetesResource, L extends Array<T>>(array: L, msg: any, service: NamespacedResourceService<T, L>, objType: {
        new (): T;
    }, namespace: string): L;
    protected upsertItem<T extends KubernetesResource, L extends Array<T>>(array: L, resource: any, service: NamespacedResourceService<T, L>, type: {
        new (): T;
    }): L;
    protected deleteItemFromArray<T extends KubernetesResource, L extends Array<T>>(array: L, resource: any): L;
    nameOfResource(resource: any): any;
}
/**
 * Lets send the last value to any new subscriber before any new values.
 *
 * Unlike BehaviorSubject there is no need for an initial value.
 * Unlike AsyncSubject we don't need to wait for complete before sending a next event
 */
export declare class CachingSubject<T> extends Subject<T> {
    protected observable: Observable<T>;
    private _value;
    private _hasValue;
    private _subscription;
    constructor(observable: Observable<T>);
    unsubscribe(): void;
    next(value?: T): void;
    protected _subscribe(subscriber: Subscriber<T>): Subscription;
}