我怎样才能从 IObservable 获取历史记录？
我正在通过 Observable 监视股票报价流，我观察它以匹配特定条件，例如 - Observable .Empty .Where(q => q.Price > watchPrice) .Subscribe(q => { /…
是否有更简单的方法让 IObservable 异步依赖于另一个 IObservable？
我是 RX 的新手，我想要的场景运行良好，但在我看来必须有一种更简单或更优雅的方法来实现这一点。我拥有的是 IObservable，我想通过触发异步操作来订…
如何连接多个 IObservable 序列？
var a = Observable.Range(0, 10); var b = Observable.Range(5, 10); var zip = a.Zip(b, (x, y) => x + "-" + y); zip.Subscribe(Console.WriteLin…
如何合并两个 Observables，以便当任何一个 Observables 完成时结果也完成？
我有这样的代码： var s1 = new Subject(); var s2 = new Subject(); var ss = s1.Merge(s2).Finally(() => Console.WriteLine("Finished!")); ss.Sub…
Silverlight ObservableCollection v. .NET 反应式扩展 (Rx)
我想我在这里遗漏了一些东西，但我刚刚阅读了 杰西·自由 关于 .Net 的反应式扩展。他的示例是使用 Silverlight 的 Window Phone 7，但 Silverlight 也…
.net Rx：消息的按顺序批处理
我正在尝试使用 Rx 实现异步工作流程，但我似乎做得完全错误。 我想做的是： From an undefined asynchronous stream of un-parsed message strings (…
如何在 Rx 中使用返回 IObservable> 的新 BufferWithTimeOrCount而不是 IObservable>
在 Windows Phone 7 上，IObservable 有一个新版本的 BufferWithTimeOrCount 扩展方法，它返回“流的流”而不是以前的“列表的流”。我在尝试使用新方…
我如何才能实现 IObservable多线程？
我根据 [Rx DEVHOL202] 和 http://rxwiki.wikidot.com/101samples#toc48 中的示例编写了一个实现， 这是我的代码。 http://csharp.pastebin.com/pm2NA…
将 Observable.FromEvent 与 WebClient.DownloadProgressChanged 结合使用
我正在尝试使用响应式扩展 (Rx) 订阅 WebClient.DownloadProgressChanged。据我所知，因为 DownloadProgressChanged 使用自定义委托类型，所以我需要…
使用随时间变化的任意布尔条件过滤 Touch.FrameReported IObservable
我一直在尝试 Windows Phone 7 中的响应式扩展 (RX)，并且非常接近可行的解决方案，但遇到了一个小细节。我正在尝试使用 Touch.FrameReported 和 Obse…
反应式扩展：将 IObservable 中的值配对
给定： class CharPair { char _a; char _b; CharPair(char a, char b) { _a = a; _b = b; } } IObservable keyPresses = ... // a sequence of key p…
窗口操作符不能与自身一起工作？
我有一些代码希望以某种方式工作，但事实并非如此，我想知道我做错了什么： class Program { static void Main(string[] args) { var ints = Observab…
各种 ISubject 实现的作用是什么以及何时使用它们？
我非常清楚Subject类的作用以及何时使用它，但我刚刚浏览了msdn上的语言参考，发现还有各种其他ISubject实现，例如： AsyncSubject BehaviorSubject R…
