c#-如何使用Reactive Extensions(Rx.Net)等待值或直到经过固定时间

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c#-如何使用Reactive Extensions(Rx.Net)等待值或直到经过固定时间，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1047字，纯文字阅读大概需要2分钟。

内容图文

我想等待(阻塞)线程,直到某个时间过去或另一个流泵入一个值,我以为以下方法可以实现此目的,但是由于第一个流为空,因此它引发了异常,

 // class level subject manipulated by another thread...
 _updates = new Subject<Unit>();
 ...
 // wait for up to 5 seconds before carrying on...    
 var result = Observable.Timer(DateTime.Now.AddSeconds(5))
    .TakeUntil(_updates)
    .Wait();

如何获得长达5秒钟的阻塞能力,或者直到另一股视频流产生一个值为止？

解决方法:

您可以像这样使用Observable.Timeout：

 var result = _updates.Take(1).Timeout(DateTime.Now.AddSeconds(5)).Wait();

我使用Take(1),因为超时期望序列完成,而不仅仅是产生下一个值.在超时时,它将抛出System.TimeoutException.

如果您不希望出现异常,则可以使用Catch来提供一些值：

var result = _updates.Take(1).Timeout(DateTime.Now.AddSeconds(5))
    .Catch(Observable.Return(default(Unit))).Wait();
// should catch specific exception, not all

如果您的单位确实是@Shlomo提到的rx单位-您可以这样更改：

var result = _updates.Select(c => (Unit?) c).Take(1)
    .Timeout(DateTime.Now.AddSeconds(5)).Catch(Observable.Return((Unit?) null)).Wait();

还是照常捕获该异常.

内容总结

以上是互联网集市为您收集整理的c#-如何使用Reactive Extensions(Rx.Net)等待值或直到经过固定时间全部内容，希望文章能够帮你解决c#-如何使用Reactive Extensions(Rx.Net)等待值或直到经过固定时间所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---