RxJavaに相当するorElseとは

Question

他の言語のストリーム/機能土地には、orElse（）という共通の操作が1つあります。 ifは、ifのように機能し、現在のチェーンに結果が得られなかった場合は、代わりのものに変更されます。 Maybe型の言語では、基本的にはSome型のチェーンを続けるか、None型のorElseに変更します。

理想的な場合：

Observable.just(false) 
      .filter(value -> { return value; }) 
      .map(value -> { return 1; }) 
      .orElse(Observable.just(0)); 

Observable.<Boolean>error(new IllegalStateException("Just playing")) 
      .filter(value -> { return value; }) 
      .map(value -> { return 1; }) 
      .orElse(Observable.just(0)); 

それは現在、連結とtakeFirstを使用して再現することができますが、それは意味的に全く同じではありませんし、適切なエラー処理をカバーしていません。

Observable.concat(Observable.just(false) 
          .filter(value -> { return value; }) 
          .map(value -> { return 1; }), 
        Observable.just(0)) 
      .takeFirst(); 

Answer 1

、彼らがいることが、異なる命名しているように見えます：defaultIfEmptyまたはswitchIfEmpty。

Observable.just(false) 
     .filter(value -> value) 
     .map(value -> 1) 
     .defaultIfEmpty(0) 
     .subscribe(val -> { 
      // val == 0 
     }); 

Observable.just(false) 
     .filter(value -> value) 
     .map(value -> 1) 
     .switchIfEmpty(Observable.just(0)) 
     .subscribe(val -> { 
      // val == 0 
     }); 

// Error thrown from the first observable 
Observable.<Boolean>error(new IllegalStateException("Crash!")) 
     .filter(value -> value) 
     .map(value -> 1) 
     .switchIfEmpty(Observable.<Integer>error(new IllegalStateException("Boom!"))) 
     .subscribe(val -> { 
      // never reached 
     }, error -> { 
      // error.getMessage() == "Crash!" 
     }); 

// Error thrown from the second observable 
Observable.just(false) 
     .filter(value -> value) 
     .map(value -> 1) 
     .switchIfEmpty(Observable.<Integer>error(new IllegalStateException("Boom!"))) 
     .subscribe(val -> { 
      // never reached 
     }, error -> { 
      // error.getMessage() == "Boom!" 
     });