c# – 重置计数超过最大时间间隔,在基于Rx计数的聚合中

发布时间：2020-12-15 06:42:10 所属栏目：百科来源：网络整理

导读：基于计数的过滤,没有时间限制 IObservable filteredStream = changes.Buffer(3); 如何引入不活动重置？但是如何引入超时TimeSpan太长,以便每当两个值之间的间隔超过此最大值时,计数将从零开始重新启动？解决方法我认为这是你以后. var longGap = source.T

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

IObservable filteredStream = changes.Buffer(3);

如何引入不活动重置？

但是如何引入超时TimeSpan太长,以便每当两个值之间的间隔超过此最大值时,计数将从零开始重新启动？

解决方法

我认为这是你以后.

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>

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!