RxJavaストリームの途中で非同期操作を条件付きで追加するにはどうすればよいですか？ここ

Question

は、私がasyncOperation()への呼び出しに絞ると、火災にそのコールバックのストリーム待ちの残りの部分を作るにはどうすればよい

makeServerCall() 
       .doOnNext { 
        doStuff(it) 
       } 
       //TODO: if it == 0, call asyncOperation() and wait for its callback to fire 
       //before running the rest of the stream. Otherwise immediately run the rest 
       //of the stream 
       .flatMap { 
        observable1(it) 
        observable2(it) 
        Observable.merge(
          getSpotSearchObservable(observable1), 
          getSpotSearchObservable(observable2) 
       } 
       .subscribeBy(onNext = { 
       allDone() 
        view? 
       }) 

（KotlinとRxJavaを使用して）私は何をしようとしているの簡易版です特定の条件が満たされている場合のみ？これはおそらくRxでの簡単な操作だと思われますが、明白な解決策は考えていません。

Answer 1

FlatMap it！

.flatMap { 
    if (it == 0) { 
     return@flatMap asyncOperation() 
      .ignoreElements() 
      .andThen(Observable.just(0)) 
    } 
    return@flatMap Observable.just(it) 
} 
.flatMap { 
    observable1(it) 
    observable2(it) 
    Observable.merge(
     getSpotSearchObservable(observable1), 
     getSpotSearchObservable(observable2) 
    ) 
}