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))不会每秒产生一个值 – 它在观察者完成和下一个观察者开始之间产生一秒的间隔.
所以,如果你有一个长时间运行的观察者,你将在一个完成和下一个开始之间仍然有一整秒.
