rx-java - 一个 Observable 应该基于另一个 Observable 发射的项目发射项目，并且两个 Observable 都没有连接

Question

我有两个不同的 Observable，它们的行为如下

可观察的一种行为 -> 这将被创建，并且一个 DisposableObserver 将订阅它并对 Observable One 发出的项目做出反应。这将持续运行，直到应用程序关闭。

可观察的两个行为 -> 这将在不同的时间被创建并订阅到不同的观察者，并且在订阅之后，这应该根据订阅可观察的两个后观察者发出的值发出值。一旦工作完成 Observable 两个订阅将被处理，但 Observable 一个应该继续。

如何使第二个 Observable 基于 Observable 发出的值发出值并在完成后处理它？

Answer 1

如果observableOne只能有一个订阅，您可以通过几种方式进行。最简单的方法是引入一个Subject; 它将被订阅observableOne，所有其他订阅者都将订阅该主题：

PublishSubject<DataType> observableOneStream = PublishSubject.create();

observableOne
  .subscribe( observableOneStream );
...
observableOneStream.subscribe( firstSubscription );
...
observableOneStream.subscribe( secondSubscription );

Answer 2

您可以flatMap将 Observable 1 的值转换为 Observable 2。

observableOne.flatMap(obsOneValue -> observableTwo(obsOneValue))
        .subscribe(obsTwoValue -> {

        });

然后你可以有一个方法Observable<ObsTwoValue> observableTwo(ObsOneValue obsOneValue)，它会基于 Observable 一个发射创建 Observable 两个。