如何在 Rx 中实现 ZipLongest

Question

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

也就是说，如果序列 1 是 [0,1,2]，序列 2 是 [0,1,2,3

]，我希望结果是 [（0,0）、（1,1）、（2,2），（2,3）]。

我试图根据现有的运算符（如Zip或CombineLate）来考虑实现它的方法，但实际上它似乎比乍一看要棘手一些。

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 });
    }));