scala - Scala 中的反应式扩展 (Rx) - 在给定时间间隔后执行方法

Question

由于我对 Reactive Extensions 很陌生，所以我对以下事情感到好奇。

通过在 Scala 中使用 Rx，我希望能够调用每秒从 API 检索内容的方法。

到目前为止，我已经了解了 Rx 中使用的创建运算符，例如 Interval、Timer 等。但不幸的是，我无法提出正确的解决方案。

有没有人有这方面的经验，最好是分享代码示例？

提前致谢！

Answer 1

使用 RxJava：

Observable.interval(1, TimeUnit.SECONDS)
          .map(interval -> getSuffFromApi()) //Upto here, we have an observable the spits out the data from the API every second
          .subscribe(response-> System.out.println(response)); //Now we just subscribe to it

或者：

Observable.interval(1, TimeUnit.SECONDS) //Emit every second
          .subscribe(interval ->System.out.println(getSuffFromApi())) //onNext - get the data from the API and print it