最初の結果を観測値リストから返します。空の場合はエラーを返します。

Question

List<Observable<?>>があります。すべてが（空だった場合、私は.switchIfEmpty(Observable.error(RuntimeException())))を行うことができます

を現在、私はこのようなものを持っている：。

Observable.fromIterable(listOfObservables) 
     .take(1) 
     .switchIfEmpty(Observable.error(RuntimeException())) 

このコード扱うだけ最初の放出された値を取得し、すべての観測が空が、ドンだった場合はエラーを返しますエラーケースを処理しません。その部分をどのように解決できるか考えてください。

Answer 1

このコードは、あなたが要求し、最後まで遅延エラーとして

Observable 
    .fromIterable(listOfObservables) 
    .concatMapDelayError(i -> i) 
    .take(1) 
    .switchIfEmpty(Observable.error(new RuntimeException())) 

concatMapDelayErrorが観測順次処理するやりたいはずですので、すべての観測可能なエラーがある場合は、集約のすべての例外を除いてCompositeExceptionを取得します。