基于计数的过滤,没有时间限制
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>
