轻松取消将你的观察取消订阅

你必须在组件或指令级别提供 SubscriptionService,因为它没有在根中提供,而且它与组件/指令的生命周期同步. 只有在此之后，您才能注入并开始使用它。

由 count$ 发出的值将被记录下来,直到组件被销毁. 你不必手动退订.

@Component({
  /* class metadata here */
  providers: [SubscriptionService],
})
class DemoComponent implements OnInit {
  constructor(private subscription: SubscriptionService) {}
  ngOnInit() {
    const source$ = interval(1000);
    const nextFn = value => console.log(value * 2);
    const errorFn = error => {
      console.error(error);
      return of(null);
    };
    this.subscription.addOne(source$, nextFn, errorFn);
  }

或者,你可以传递一个观察者.

addOne 方法返回单个订阅以便你以后使用它. 有关详细信息,请参见下面的主题.

有两种方法可以做到这一点. 如果你不想再次订阅.可以使用 closeAll 方法.

@Component({
  providers: [SubscriptionService],
})
class DemoComponent implements OnInit {
  constructor(private subscription: SubscriptionService) {}
  ngOnInit() {
    this.subscription.addOne(interval(1000), console.log);
  }
  onSomeEvent() {
    this.subscription.closeAll();
  }
}

有时你可能需要取消订阅特定的订阅,但保留其他订阅. 在这种情况下,你可以使用 closeOne 方法.

@Component({
  /* class metadata here */
  providers: [SubscriptionService],
})
class DemoComponent implements OnInit {
  countSubscription: Subscription;
  constructor(private subscription: SubscriptionService) {}
  ngOnInit() {
      console.log
    );
  }
  onSomeEvent() {
    this.subscription.closeOne(this.countSubscription);
    console.log(this.countSubscription.closed); // true
  }
}

你可能需要控制特定的订阅. 在这种情况下你可以使用 removeOne 方法将其从跟踪的订阅中删除.

使用 isClosed 检查 closeAll 是否被调用.

@Component({
  /* class metadata here */
  providers: [SubscriptionService],
})
class DemoComponent implements OnInit {
  constructor(private subscription: SubscriptionService) {}
  ngOnInit() {
    this.subscription.addOne(interval(1000), console.log);
  }
  onSomeEvent() {
    console.log(this.subscription.isClosed); // false
  }