如何实现从一个IObserver到另一个IObserver的原子切换？
我有一个 IObservable，我使用一些中间步骤将其转换为 IObservable： var observedXDocuments = from b in observedBytes // Lot of intermediate ste…
在 C# 中使用 Rx Reactive 扩展时出现 linqpad 错误
我做错了什么？我刚刚下载了最新的Rx sdk，安装了。使用 vs 2010，.net 4 具有所有最新的 sp/更新等。下载/安装了 linqpad，添加了对反应 dll 的引用…
反应式扩展 - 新版本中旧版本使用方法的问题
我是 .NET 的新手，我之前的工作是 PLC 程序员。我有一个旧应用程序，其中使用了 .NET 的响应式扩展。 我维护这个应用程序的时间不长。现在我下载了反…
Observable.Timer() 会导致内存泄漏吗？
最近，我注意到我的代码中使用反应式扩展的一个小错误。我正在订阅 Timer，但我从未放弃我的订阅。这导致了内存泄漏。 我创建了强调这种危险的片段： …
将字符串的 IObservable 转换为 XDocuments 的 IObservable
我有一个包含 XML 文档（片段）的 IObservable。我想将其中一种转变为另一种。例如，假设我有以下从 IObservable 推送的片段（每行包含一个片段）： <…
反应式扩展Subject>到主题>
我在获取主题 public Subject> PersonDataSubject; 并将其转换为： public Subject> BornInYearSubject; ...使用一些 linq 聚合时遇到问题。 下面的示…
如何取消使用 Rx 调用的异步方法
我想知道如何使用 TakeUntil 取消\停止使用反应式扩展调用的异步方法。 所以我希望能够取消\停止以下方法： this.booksService.Search(searchText) .O…
检测 IObservable 上的 IsAlive
我正在编写一个函数 IsAlive 来获取 IObservable 和时间跨度，并返回 IObservable 规范使用案例是检测流媒体服务器是否仍在发送数据。 我为此提出了以…
如何更改 Rx Builder 实现来修复堆栈溢出异常？
我正在尝试提出一个 Rx Builder，以在 F# 计算表达式语法中使用反应式扩展。我该如何修复它，以免堆栈崩溃？就像下面的 Seq 例子一样。 是否有计划提…
.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…
