Observable 由冷和热 observables 组成

Question

我很难找到合适的方法来组合一个 observable，它将从给定的冷 observable A 发出所有项目，并且一旦它完成，就会继续使用 hot observable B。

这是我的特定用例：我有一个数据收集器，它实时将数据附加到仅附加数据库（事件流）。当一个请求到达流所有事件流时，它应该开始从数据库中流式传输所有内容，一旦数据库没有更多数据，它就会开始流式传输任何收集器流......正如你看到的那样，两者都可以作为 observables 使用。

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

这是此行为的图表：

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。

Answer 2

我怀疑你需要的是 2 个队列，而不是 observables。

QueueA 具有优先级，而 QueueB 仅在 QueueA 获得退出/消息结束信号时才被处理。

您认为这种情况可能合适吗？