如何创建iobservable<t>它每隔-n秒返回一个值,而不跳过任何

我最近通过创建一个 Observable that emits timed events every timeInterval . 然后,您可以使用zip方法将可观察到的事件与可观察到的计时器事件同步。

例如:

    var timer = 
        Observable
            .Timer(
                TimeSpan.FromSeconds(0), 
                TimeSpan.FromSeconds(2)
            );
    var source = Observable.Range(1, int.MaxValue);
    var timedSource = source.Zip(timer,(s,t)=>s);
    timedSource.Subscribe(Console.WriteLine);

使用Observable.GenerateWithTime:

var source = Observable.GenerateWithTime(1, _ => true, x => ++x, x => x, x => TimeSpan.FromSeconds(2));

可观测范围使用可观测生成,所以这是一种方法。还有很多其他的方法。

对于更高级的东西,例如以相同的方式处理事件(因为这显然只在您自己生成数据时有帮助),请参见 How to throttle event stream using RX? 已经解决了这个问题。