Rxjava，如何设计一个必须等待另一个 Observable 的 Observable答案

【问题标题】：Rxjava, how to design an Observable that has to wait for another ObservableRxjava，如何设计一个必须等待另一个 Observable 的 Observable
【发布时间】：2015-05-12 13:57:22
【问题描述】：

我正在构建一个 Android 应用程序，并且是 Rxjava 的新手，有一个初学者的问题：如果满足条件，我有一个 Observable 应该立即发出一些东西。否则，它必须暂停，然后触发另一个 Observable，并等待第二个 Observable 发出第二件事。一旦发出第二个东西，它（第一个 Obserable）应该继续并发出它的对象。

是否应该将第二个 Observable 放在第一个 Observable 的“调用”函数中？

如果这个问题听起来含糊不清，请原谅我，因为我什至不确定如何设计代码。

【问题讨论】：

标签： android rx-java

【解决方案1】：

您尝试“触发”和“暂停”的这些可观察对象是什么？如果我正确理解您的问题，您可以这样做（而不是从头开始创建 Observable）：

Observable<Integer> first = Observable.just(1, 2, 3);
Observable<Integer> second = Observable.just(4);

Observable<T> toRun;

if (condition) {
    toRun = first;
} else {
    toRun = second.concatWith(first);
}

toRun.toBlocking().forEach(System.out::println);

【讨论】：

【解决方案2】：

试试看这个答案RxJava: how to compose multiple Observables with dependencies and collect all results at the end?

还可以考虑阅读nice post of Dan Lew 以及his introduction to RxJava

【讨论】：