c# - 接收.NET : Take until specified count or timer elapsed

Question

我有一个接收 Observable 通知的解决方案，直到指定计数到达或时间阈值过去。另外，我需要知道发生了什么。

想知道是否有更简单的方法(可能不是 GroupByUntil)来实现此功能

_values.
.GroupByUntil(_ => true,
              i => Observable.Timer(Threshold, _scheduler)
                             .Amb(i.Buffer(SpecifiedCount).Select(_ => SpecifiedCount)))
// this is for figuring out which one happened: interval elapsed or count filled
.SelectMany(g => g.Count())
// Let's say if count filled first, call Foo()
.Where( i => i == SpecifiedCount ) 
.Subscribe( _ => Foo() )

Answer 1

你在找Observable.Buffer Method (IObservable, TimeSpan, Int32)吗？根据文档

Indicates each element of an observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed.

你应该能够写:

var myObservable=_values.Buffer(Threshold,SpecifiedCount);

Window 也有类似的重载