angular.js rxjs misc

angularjs-rxjs-utils.ts

/** AngularJS function to unsubscribe from observables when scope destroyed.
 * @param $scope - Scope that is listening to an observable.
 */
export function registerDestroyedObservable($scope: any) {
  if($scope.destroyed$) {
    return;
  }

  $scope.destroyed$ = new Subject();
  $scope.$on('$destroy', () => {
    $scope.destroyed$.next();
    $scope.destroyed$.complete();
  });
}

export function takeUntilScopeDestroyed<T>($scope: any) {
  registerDestroyedObservable($scope);
  return takeUntil<T>($scope.destroyed$);
}