Observable.Interval在每个时间段产生值.如何让它等到行动在下一次迭代之前结束？

例：

Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe(async t => 
{
    //Here could be some long running action with different duration each iteration
    Console.WriteLine(t.ToString());
    await Task.Delay(3000);
});

它将每秒开始行动.如何让它等到行动完成？

解决方法:

您要求的是默认行为 – 除非您引入async / await – 因此请删除异步并使用Task.Delay(3000).Wait().

Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe(t => 
{
    //Here could be some long running action with different duration each iteration
    Console.WriteLine(t.ToString());
    Task.Delay(3000).Wait();
});

只有观察者完成后,可观察对象的合同才会产生新的价值 – 除非你引入异步.

Observable.Interval(TimeSpan.FromSeconds(1))不会每秒产生一个值 – 它在观察者完成和下一个观察者开始之间产生一秒的间隔.

所以,如果你有一个长时间运行的观察者,你将在一个完成和下一个开始之间仍然有一整秒.