我有一系列事件,每10-1000毫秒发生一次.我订阅了这个事件来源,但希望以500ms的固定(或最小)间隔处理它们.我也想一次处理一个事件,而不是批处理(比如Buffer(x> 1)).
伪代码中的这样的东西:
observable.MinimumInterval(TimeSpan.FromMiliseconds(500)).Subscribe(v=>...);
试过例如:
observable.Buffer(1).Delay(TimeSpan.FromMiliseconds(500).Subscribe(v=>...);
以及许多其他潜在的解决方案.到目前为止没有运气.
有任何想法吗？