RxJava - Observableが完了するのを待つ

Question

Observableという2つのシーケンス、すなわちObservable1とObservable2があります。これらは両方とも分離したスケジューラー上で実行されます。

Observable1は、データベースからデータをフェッチしますが、Observable2は、サーバーから同じデータをフェッチします。

これらの2つの結果は、被験者を用いてObserverに送信される。

インターネットに接続できない場合、Observable2は、Observable1がonNext()イベントを送信する前にonError()を実行します。

Observable1がonNext()イベントを発生させるのを待つ方法Observable2が発光しますか？あなただけの各観測の終わりに.onErrorResumeNext(Observable.empty())を追加し、エラーコードを気にしない場合は

Observable1 = dataRepo.getItems().doOnNext({ serializedSubject.onNext(items)}).subscribeOn(Schedulers.io());

Observable2 = cloudRepo.getItems().doOnNext({ dataRepo.addAll(items) dataRepo.getItems().subscribe(serializedSubject)}). subscribeOn(Schedulers.io());

Observable.mergeDelayError(Observable1, Observable2) .subscribeOn(Schedulers.io()).subscribe(new Subscriber());

Answer 1

;：ここ

は、いくつかのコードです通常のmergeオペレータが必要です。