java - Observable 由冷和热 Observable 组成

Question

我很难找到组成一个可观察对象的正确方法，该可观察对象将从给定的冷可观察对象 A 中发出所有项目，并在其完成后立即继续使用热可观察对象 B.

这是我的具体用例:我有一个数据收集器，它实时将数据附加到仅附加数据库(事件流)。当一个流式传输所有事件流的请求到达时，它应该开始流式传输数据库中的所有内容，一旦数据库没有更多数据，它将开始流式传输任何收集器流……正如您所见，两者都可作为可观察对象使用。

我是响应式编程的新手，因此我的问题可能有点抽象。任何帮助表示赞赏。

这是此行为的图表:

B ----B---B---B----B--B---B---B---X------>
                   |  |   |   |   |
                   |  |   |   |   |
R --A---A--A----?--B--B---B---B---X------>
    |   |  |    |
    |   |  |    |
A --A---A--A----X------------------------>

这里 R 是我们的可观察结果，A 是冷的，B 是热的。 R 以 B 结束。

Answer 1

如果 B 是热的，那么简单的 A.concat(B) 应该可以工作，因为只有当 A 完成时 B 才会被订阅。