typescript 取消订阅Observables

Posted 2021-05-20

import { OnDestroy } from '@angular/core';
import { Subject } from 'rxjs';

export class ObservableComponentBase implements OnDestroy {
  protected ngUnsubscribe: Subject<void> = new Subject<void>();

  /**
   * unsubscribe to all subscriptions
   */
  ngOnDestroy() {
    this.ngUnsubscribe.next();
    this.ngUnsubscribe.complete();
  }
}


// Usage
export class MyComponent extends ObservableComponentBase implements OnInit {
  
   ngOnInit() {
    this.commission$ = this.facade.commission$.pipe(
      takeUntil(this.ngUnsubscribe)
      );
   }
}