export interface ISubscribable<T> {
    subscribe: (observer?: IPartialObserver<T>) => ISubscription;
    isEqual?: (subscribable: ISubscribable<T>) => boolean;
}
export interface ISubscription {
    unsubscribe: () => void;
}

export interface IPartialObserver<T> {
    next?: (value: T) => any;
    error?: (err: any) => any;
    complete?: () => any;
}