问突发性数据的反应性积累

EN

因为您只想要求和，所以使用Buffer就太过分了。我们可以运行Scan或Aggregation。

  var burstSum =
    source
        .Scan(0, (acc, current) => acc + current)
        .Throttle(TimeSpan.FromMilliseconds(500))
        .Take(1)
        .Repeat();

这将启动一个流，该流累加该总和，直到该流已空闲至少500 at。

但如果我们想至少每次发射桶，我们将不得不走一条不同的道路。我们做了两个假设：

元素之间的时间间隔之和应该等于第一个和最后一个element.

• Throttle之间的时间间隔，在流完成时将释放最后一个值。

源.TimeInterval() .Scan((acc，cur) => new (acc.Value+ cur.Value，acc.Interval + cur.Interval)) .TakeWhile(acc => acc.Interval <= TimeSpan.FromMilliseconds(500) .Throttle(TimeSpan.FromMilliseconds(500)) .Throttle( TimeSpan.FromMilliseconds(500)) .Select(acc => acc.Value) (1)()；en21#