0

誰かがここでヒントをくれないかと思っていました。私は 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))

マルコに感謝します

4

0 に答える 0