import { Observable, Subscription } from 'rxjs';
export declare class PubSub extends Subscription {
    static displayName: string;
    private readonly logger;
    private map;
    constructor();
    private getSubject<T>(key);
    observe<T>(key: string): Observable<T>;
    subscribe<T>(key: string, onNext?: (value: T) => void, onError?: (exception: any) => void, onCompleted?: () => void): Subscription;
    publish<T>(key: string, arg: T): void;
}
export declare const Default: PubSub;
export declare function observe<T>(key: string): Observable<T>;
export declare function subscribe<T>(key: string, onNext?: (value: T) => void, onError?: (exception: any) => void, onCompleted?: () => void): Subscription;
export declare function publish<T>(key: string, arg?: T): void;