.NET Reactive框架:ReplaySubject OnError:为什么会抛出异常?
注意:我指的是 .NET 4 版本的 RX。 我一直在使用 RX 的 ReplaySubject 类。我正在调用 OnError,并以异常作为参数。 我原以为它会通知所有 OnError …
ObserveOn 与 Scheduler.NewThread 不会观察到,如果观察者的 OnNext 被阻止并继续
有人可以帮助解释为什么当我“阻止并继续”观察者的 onNext 序列订阅具有时间可观察序列的缓冲区时, Scheduler.NewThread 不再适用吗? 例如: 如果…
ObserveOnDispatcher 不工作
我有 2 个线程,WPF+PIPE。我在管道 rx 事件上从 WPF 注册。 当使用 ObserveOnDispatcher() 时,不会调用注册的处理程序,当删除 ObserveOnDispatcher…
响应式框架消除了 Observable.Create 中的 while 循环
我正在处理来自网络的可观察字节流,我想将其提升到一层抽象。该格式有两个字节,其中包含下一条消息的长度。我想让它很好地适应反应式框架。到目前为…
使用 Linq to SQL 和 Rx 处理数据库连接异常
我正在尝试学习如何最好地使用 Reactive Extensions 库,并设置了简单的测试 WPF 应用程序来查看日志记录数据库表。在 ViewModel 类中,我使用 Linq t…
Silverlight 的反应式扩展 (Rx) - System.Interactive.dll 移至何处?
我刚刚安装了 Silverlight 4 和 5(测试版)的最新 Rx 版本 (v1.1.10425)。我发现该包缺少我过去在项目中使用过的 3 个 DLL: System.CoreEx.dll Syst…
需要 RX 方面的帮助:将 System.Diagnostics.Process.OutputDataReceived 转换为 Observable
我想启动一个子进程并观察它的重定向输出。那不是 C# 对我来说是一个问题,但我尝试理解 RX,所以游戏开始了...... 我有一个用于进程的静态扩展方法,…
HttpWebRequest 异步调用填充堆栈并剥离 Windows Phone 上的反应式扩展
我正在编写一些代码,将文件从网络资源下载到磁盘。从网络读取和写入都是异步完成的。我观察到一个问题,异步调用实际上是同步调用的,因此每次新的迭…
生成的 RIA 实体“单元”与 Rx“Unit”冲突;
我有一个使用 RIA 服务的 Silverlight 应用程序。其中一个实体名为 Unit。我最近尝试使用响应式扩展,但是当我添加对 System.CoreEx 的引用时,我遇到…