scala - 複数の完了ルーチンを登録する

Question

私はObservableから構築されたものを持っていますStream[Item]（Itemこれは単なる例です）このオブザーバブルは一連の変換を通過します：

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

各変換 (1 番目と 2 番目) の完了時にいくつかのアクションを実行したいと考えています。doOncompletedメソッド onobservable1を呼び出しobservable2ても、目的の効果が得られない場合 (実際には副作用は見られません)。

どうすればこれを達成できますか? これは可能ですか？

Answer 1

で情報を記録してみました.doOnNext()か? どちらのオブザーバブルも完了していない可能性があり、.doOnCompleted()呼び出されなかった理由が説明されています。完全に副作用が必要な場合は、オブザーバブルが完了していることを確認してください。