export interface Subscription {
    closed: boolean;
    unsubscribe(): void;
}
/**
 * Even stream used to recieve live updates for specific object T
 */
export interface PushStream<T> {
    finishSubscriptions(): void;
    publish(message: T): void;
    subscribe(listener: (message: T) => void, filter?: (value: T) => boolean): Subscription;
}
export declare class ObservablePushStream<T> implements PushStream<T> {
    private observable;
    private observers;
    constructor();
    finishSubscriptions(): void;
    publish(message: T): void;
    subscribe(listener: (message: T) => void, filter?: (value: T) => boolean): ZenObservable.Subscription;
}