如何在 Rx 中实现 ZipLongest？答案

【问题标题】：How can you implement ZipLongest in Rx?如何在 Rx 中实现 ZipLongest？
【发布时间】：2015-03-13 02:14:32
【问题描述】：

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

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

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

【问题讨论】：

我想你不会提前知道可观察序列的长度吗？
不，我不知道，但我仍然很好奇这会有什么帮助......
我正在考虑连接较短序列产生的最后一个值的重复序列，但要知道哪个更短以及更长的时间需要多长时间。这是个坏主意。对不起。

标签： c# system.reactive observable

【解决方案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 });
    }));

【讨论】：