RxJava：d​​oOnEmptyのようなコードを作成するには？

Question

私はObservableにいくつかのフィルタを使用しています。結果が空の場合、フィルタリングの最後にケースを報告したいと思います。

 Observable.just(1, 2, 3) 
       .concatWith(
         Observable.just(2, 4, 6) 
           .filter(value -> ((value % 2) != 0)) 
           // report if empty 
       ) 

Answer 1

あなたはTransformers.doOnEmptyを使用することができ、このフォールバックで何かを行うことができます：この観察できるが、別の1と連結されるようになっているので、私は、処理の最後にそれを行うことはできませんrxjava-extrasからMavenの中央にある：

source.compose(Transformers.doOnEmpty(action)) 

あなたが世話場合は、このソリューションを使用する場合があります効率（配分/パフォーマンス）については、@ dwursteisenのソリューションを使用してください。

Answer 2

あなたはswitchIfEmptyを使用してObservable

Observable.just(2, 4, 6) 
      .filter(value -> ((value % 2) != 0)) 
      // replace the empty observable with an empty observable 
      // but this observable will log when it will completed 
      .switchIfEmpty(Observable.<Integer>empty().doOnTerminate(() -> System.out.println("empty !"))) 
      .subscribe();