java - RxJava 结合 Observables

Question

我想将多个可观察对象的结果组合成一个父可观察对象。我无法一次访问所有可观察对象，它们将在整个程序执行期间被订阅。

到目前为止，这是我的方法:

...
compoundObservable = compoundObservable.mergeWith(firstObservable);
...
compoundObservable = compoundObservable.mergeWith(secondObservable);
...

该方法没有奏效，因为 otherObservable 发送的事件没有被 compoundObservable 的订阅者注册。

我怎样才能组合这些观察值？

Answer 1

使用 Subject 您可以随时订阅可观察对象，该主题的所有订阅者都将获得所有项目。不过，这在调试时可能有点棘手。

PublishSubject<Object> subject = PublishSubject.create();
Observable<Object> observable1 = ...;
observable1.subscribe(subject);

subject.subscribe(...) // will eventually also get emisions from observable2

Observable<Object> observable2 = ...;
observable2.subscribe(subject);