scala - Scala の Reactive Extensions (Rx) - 特定の間隔でメソッドを実行する

Question

私は Reactive Extensions にまったく慣れていないので、次のことに興味がありました。

Scala で Rx を使用することにより、API からコンテンツを取得するメソッドを毎秒呼び出せるようにしたいと考えています。

これまで、Interval、Timer などの Rx 内で使用される作成演算子を見てきました。しかし、残念ながら、私は正しい解決策を思い付くことができません。

誰かがこれについての経験があり、できればコード例を共有していますか?

前もって感謝します！

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