反应式编程：当流空闲一段时间时发出指定的元素

Question

我有一个可观察的对象，我想在一段时间后（超时）发出一个默认元素，同时保持流仍然打开，以便将来发出新值。我该怎么做？

我试图通过将原始流与另一个流合并来实现这一点，该流将原始流去抖动，同时将去抖动值映射到我想要的默认值。

伪代码：

defaultDebounced = originalStream.debounce(time).map({x -> myDefaultValue})
myStream = rx.merge(originalStream, defaultDebounced)

虽然我不知道我是否会遇到一些像下面这样的边界情况，其中原始流在超时触发时发出一个项目，并且偶然地，默认值在之后被发出。

original:  ----A----B----------------------C------------
debounced: -----------------------<timeout>X------------
merged:    --------------------------------CX-----------

此外，还有一个缺点，即第一个可观察对象必须发出至少一个项目，才能使去抖动发出默认值。

注意：我想知道正确的rx方法来实现它，不管实现如何，但只是为了以防万一，我正在使用RxSwift。

Answer 1

我最后做的是：

originalStream.flatMapLatest({x -> 
    return Observable.timer(30, scheduler: MainScheduler.instance)
        .map{_ -> defaultValue}
        .startWith(x)
})