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