RxJava棘手的startWith（可观测）

Question

下面的代码仅在观察2完成后才从观察1发出项。

observable1.startWith(observable2)
           .subscribe()

我需要实现另一种行为

observable1 ->       0   1   2   3
observable2 -> 1   2   3   4   5   6

observable1.startWithDefault(observable2)
            -> 1   2 0   1   2   3

第二个可观测对象仅发射项目，而第一个可观测对象为空，然后发射第一个可观测对象的项目。

我无法找到只使用基本运算符的正确解决方案，自定义运算符startWithDefault的正确RxJava 2实现应该是什么样子？

附笔。

observable1.subscribe()
observable2.takeUntil(observable1).subscribe()

由于种族原因，在可观察到立即发射的情况下，这不是正确的解决方案1

Answer 1

方向是好的，但你需要发布（函数）共享观察1的信号，并且concatEager在开关应用时不会丢失其中的元素：

observable1.publish(o -> 
    Observable.concatEager(observable2.takeUntil(o), o)
)
.subscribe(...)