Rx。NET:直到指定的计数或计时器结束

我有一个接收的解决方案 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() )