如何暂停 Observable？

Question

我正在开发我的第一个 Angular 2 产品。我创建了这个Observable.timer，然后订阅了它。它轮询服务器以获取数据。

如何暂停和取消暂停？

  ngOnInit(): void {
    this.poll = Observable.timer(500,500).subscribe((t: any) => {
      this.request.getRackList(+this.global.zoneId).subscribe(
        incoming => this.import(incoming),
        err => { this.global.err(err) }
      );
    })
    this.canOpenClose = (this.global.mode === 2);
  }

Answer 1

有多种方法可以暂停 Observable。你可以：

• 在需要时取消订阅/重新订阅
• .filter() 暂停时排放
• 创建一个connectable Observable，以便您可以暂停/开始向所有订阅者发射

Answer 2

你可以看看这里：RxJS - pause, upon resume give last paused value

基本上，您使用switchMap 运算符来停止计时器发射/重新启动它们，并使用暂停器主体发出一个布尔值，指示您是要暂停还是重新启动。 如果不需要最新值，可以将publishReplay替换为publish