在基于Rx计数的聚合中,重置计数高于最大时间间隔

Question

基于计数的过滤没有时间限制

IObservable filteredStream = changes.Buffer(3);

如何引入不活动重置？

但是如何引入超时,TimeSpan tooLong以便只要两个值之间的间隔超过此最大值,计数就会从零重新开始？

Answer 1

我想这就是你所追求的。

var longGap = source.Throttle(tooLong);
var filtered = source
  .Window(() => { return longGap; })  // Gives a window between every longGap
  .Select(io => io.Buffer(maxItems).Where(l => l.Count == maxItems))
  .Switch();  // Flattens the IObservable<IObservable<IList>> to IObservable<IList>