c# – Observable.Interval等到动作完成

发布时间：2020-12-15 22:36:22 所属栏目：百科来源：网络整理

导读：Observable.Interval在每个时间段产生值.如何让它等到行动在下一次迭代之前结束？例： Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe(async t = { //Here could be some long running action with different duration each iteration Console.Wr

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))不会每秒产生一个值 – 它在观察者完成和下一个观察者开始之间产生一秒的间隔.

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!