Rx 动态大小的滑动缓冲区

Question

我不完全确定如何表达这一点，所以如果我弄错了，我很抱歉。 我有一系列事件，我们会说如下：

0,1,2,3,4,5,6,7,8,9,...

我想为我的程序提供一个 IObservable，它返回如下所示的缓冲区：

[0],[0,1],[0,1,2],[0,1,2,3],[1,2,3,4],[2,3,4,5] ,[3,4,5,6],....

或者其他一些不是 4 的最大缓冲区大小。如果我可以像使用定时缓冲区调用那样输入缓冲区参数，那会很容易，但不会出现重载，所以我尝试构建序列手动：

target.LogEvents.Buffer(1,1).Take(1).Concat(target.LogEvents.Buffer(2,1).Take(1)).Concat(target.LogEvents.Buffer(3,1).Take(1)).Concat(target.LogEvents.Buffer(4, 1)).Subscribe(...);

但这没有用。它给了我

[0],[1,2],[3,4,5],[6,7,8,9],[7,8,9,10],....

如何生成我的序列？

Answer 1

这对你有用吗？

IObservable<IEnumerable<int>> query = 
    source
        .Scan(Enumerable.Empty<int>(), (a, x) =>
            a.Concat(new [] { x }).TakeLast(4).ToList());

您需要同时 NuGet "Rx-Main" 和 "Ix-Main" 才能工作。