import {my} from "my-ts"; import { IObserverWithSubscription } from "../../common/common.interfaces"; export const validObserver = (observerWithSubscription: IObserverWithSubscription): boolean => { if (my(observerWithSubscription).isNullOrUndefinedOrEmpty) { return false; } const observer = observerWithSubscription.observer; if (my(observer).isNullOrUndefined) { return false; } return true; }; export const observerHasActiveSubcription = (observer: IObserverWithSubscription, index: number): boolean => { if (my(observer).isNullOrUndefinedOrEmpty) { return false; } if (my(observer.subscription).isNullOrUndefined) { return false; } if (observer.subscription.closed) { return false; } return true; }; export const observerWithActiveSubcription = (observer: IObserverWithSubscription): boolean => { if (my(observer).isNullOrUndefinedOrEmpty) { return false; } if (my(observer.subscription).isNullOrUndefined) { return false; } if (observer.subscription.closed) { return false; } return true; }; export const observerWithNoActiveSubscription = (observer: IObserverWithSubscription): boolean => { if (my(observer).isNullOrUndefinedOrEmpty) { return false; } if (my(observer.observer).isNullOrUndefined) { return false; } if (my(observer.subscription).isNullOrUndefined) { return true; } if (observer.subscription.closed) { return true; } return false; };