system.reactive - 参考以前的项目 - 在 Rx 或 Rxx 中是否有任何可观察的扩展？

Question

我有一个 IObservable，我正在寻找一种方法来做这样的事情

var referenceBack2 = source.Ref(2);

说我有这个序列来自源

ABCDEFGH

referenceBack2 不会在 A 上执行 OnNext()，直到 B 来自源，不会渲染 B，直到 C 进来，最后它会渲染 G。H 将永远等待，因为 A 是热可观察的，并且 H 之后没有元素.

Answer 1

我认为这会起作用：

var referenceBack2 = source.Zip(source.Skip(1), (a, b) => a)