誰かがここでヒントをくれないかと思っていました。私は RxScala を学んでおり、次の演習を行う必要があります: - 5 秒ごとおよび 12 秒ごとにイベントを発行するオブザーバブル オブジェクトを実装します。
次のコードがそれを行うかどうか疑問に思っていましたか? OBservable コンビネータの多くのドキュメントを見つけることができませんでした
val evens = Observable.interval(5.second).filter(_ % 6 != 0)
val odds = Observable.interval(12.second).filter(_ % 5 != 0)
val merged = evens.merge(odds)
merged.subscribe(it => println(it))
マルコに感謝します