具有间隔的Angular2 Observable

Question

我有一个函数需要大约每 500 毫秒调用一次。我正在考虑使用 angular2 进行操作的方式是使用间隔和可观察量。我试过这个函数来创建可观察的：

counter() {
  return Observable.create(observer => {
    setInterval(() => {
      return this.media.getCurrentPosition();
    }, 500)
  })
}

订阅者使用此代码：

test() {
  this.playerService.initUrl(xxxx) // This works
  this.playerService.counter().subscribe(data => {
    res => {
      console.log(data);
    }
  })
}

我对 observables 和 angular2 很陌生，所以我可能完全采用了错误的方法。感谢任何帮助。

Answer 1

Observable class 有一个静态 interval 方法以毫秒为参数（类似于 setInterval 方法）：

counter() {
    return Observable
        .interval(500)
        .flatMap(() => {
            return this.media.getCurrentPosition();
        });
}

在您的组件中或任何地方：

test() {
  this.playerService.initUrl(xxxx) // This works
  this.playerService.counter().subscribe(
      data => {
          console.log(data);
      }
   );
}

具有间隔的Angular2 Observable

Angular2 Observable with interval

javascript

intervals

observable

rxjs

angular