如何在 Rx 中实现 ZipLongest？

Question

我正在尝试压缩两个不同长度的可观察序列，但我希望组合序列具有最大序列的长度，并用最短序列的最后一个值填充。

也就是说，如果序列1是[0,1,2]，序列2是[0,1,2,3]，我希望结果是[(0,0),(1, 1),(2,2),(2,3)].

我已经尝试根据现有的运算符（例如 Zip 或 CombineLatest）来考虑实现这一点的方法，但它实际上似乎比第一眼看上去要复杂一些。

Answer 1

这是我基于 Enigmativity 的想法所做的尝试：

aSource.Publish(ap => bSource.Publish(bp =>
    {
        var lastA = ap.TakeLast(1).Replay();
        var lastB = bp.TakeLast(1).Replay();
        var lastAForEachB = bp.SelectMany(b => lastA);
        var lastBForEachA = ap.SelectMany(a => lastB);

        var aWithLengthB = ap.Concat(lastAForEachB);
        var bWithLengthA = bp.Concat(lastBForEachA);

        lastA.Connect();
        lastB.Connect();
        return aWithLengthB.Zip(bWithLengthA, (a, b) => new { a, b });
    }));

如何在 Rx 中实现 ZipLongest？

How can you implement ZipLongest in Rx?

c#

system.reactive

observable