只有在另一个 Observable 接收到元素后才订阅 Observable

Question

我正在尝试在一个地方声明我的所有订阅，并且没有任何中间中继或触发器。这就是我想要实现的目标。

我有一个Signal<X>，它只会在其他所有内容都加载完毕并且工作正常后才会开始接收值。但是现在我需要介绍另一个Observable<Y>，当我订阅它时，它会立即开始发出值，因为它正在从数据库中获取数据。这有点问题，因为我的 UI 还没有准备好显示结果，并且只有在 Signal<X> 发出它的第一个值时才准备好。在此之后，我想收到Observable<Y> 将收到的每一个值。

我正在尝试使用skipUntil，这很好，但我丢失了Observable<Y> 的第一个元素。 switchLatest 也不是很好的匹配。我也在研究amb，但这也不会给我正确的结果，因为它订阅了两个序列，这不是我需要的。

我的问题是：只有在原始 Observable 收到一个值之后，是否有可能订阅其他 Observable？并保持此订阅有效，以便它对新值做出反应。

Answer 1

听起来您只需要一个简单的 flatMap 或其衍生工具之一。很大程度上取决于 X 和 Y 发射的频率以及当 X 在第一次发射后您想要做什么。

您可以通过阅读this article 了解更多信息，但下面的大理石图是一个不错的总结（它们假定默认的“冷”或惰性可观察。如果y 很热，那么情况就不同了。）：

x.flatMap { _ in y }

x   +---1---2---3---|
y       +--A--B--C--|
y           +--D--E--F--|
y               +--G--H--J--|
--
    +------A--BD-CEG-FH--J--|

或

x.flatMapFirst { _ in y }

x   +---1---2---3---|
y       +--A--B--C--|
--
    +------A--B--C--|

或

x.flatMapLatest { _ in y }

x   +---1---2---3---|
y       +--A
y           +--D
y               +--G--H--J--|
--
    +------A---D---G--H--J--|

或

x.concatMap { _ in y }

x   +---1---2---3---|
y       +--A--B--C--|
y                   +--D--E--F--|
y                               +--G--H--J--|
--
    +------A--B--C-----D--E--F-----G--H--J--|

这完全取决于您到底想要什么行为。