scala - 注册多个完成例程

Question

我有一个Observable由Stream[Item]（Item这里只是举例）构造的这个 observable 通过一组转换：

val observable: Observable[Item] = ... //construct observable from stream
val observable1: Observable[AnotherItem1] = observable.map(...) //transform to AnotherItem1
val observable2: Observable[AnotherItem2] = observable1.map(...) //transform to AnotherItem2

我想在完成每个转换（第一次和第二次）时执行一些操作。如果我调用doOncompleted方法observable1并且observable2我没有得到想要的效果（实际上我没有观察到任何副作用）。

我怎样才能做到这一点？这可能吗？

Answer 1

您是否尝试过使用 记录一些信息.doOnNext()？可能两个可观察对象都没有完成，解释了为什么.doOnCompleted()没有被调用。如果您想对完成产生副作用，请确保可观察对象已完成。