RxJava - 等待 Observable 完成

Question

我有两个Observable 序列，即Observable1 和Observable2。它们都在单独的调度程序上执行。

Observable1 从数据库获取数据，而Observable2 从服务器获取相同的数据。

这两个Observablesequences 的结果使用主题发送到Observer。

现在如果没有互联网连接，那么Observable2 在Observable1 可以发布其onNext() 事件之前执行onError()。

如何在Observable2 开始发射之前等待Observable1 发射其onNext() 事件？

这里有一些代码：

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

如果你只是不关心错误代码，在每个 Observable 的末尾添加.onErrorResumeNext(Observable.empty())；你只需要普通的merge 操作符。