system.reactive - RX - 指定速率的通知

Question

我是 RX 的新手，我面临着“调整通知流量”的问题。

我想知道如何通知具有给定吞吐量的观察者；也就是说，我希望在自上次“OnNext”调用后经过给定时间之前调用“OnNext”方法。

为了完整起见:我希望序列中的每个元素都会被通知。

例如，0.2 个符号/报价:

Tick:        0         10        20        30
             |---------|---------|---------|
Producer:    A---B------C--D-----E-------F
Result:      A    B     C    D    E      F
             0    5     11   16   21     28

有没有办法组合 Observable，或者我必须实现自己的 Subject？

非常感谢

Answer 1

是的，只需将每个值变成一个异步过程，直到延迟结束后才完成，然后将它们连接起来。

var delay = Observable.Empty<T>().Delay(TimeSpan.FromSeconds(2));
var rateLimited = source
    .Select(item => Observable.Return(item).Concat(delay))
    .Concat();