为什么 Rx Observable.Subscribe 会阻塞我的线程？
你好，我已经尝试了 101 Rx 示例之一： static IEnumerable<int> GenerateAlternatingFastAndSlowEvents() { int i = 0 while (true) { if (i >…
如何在需要的 Rx .NET / Dispose 中使用简单的超时？
使用 Rx .NET 在 3 秒后引发火灾并忘记回调的最简单方法是什么。我注意到这有效，但我必须处理它还是什么？我不知道。 Observable.Timer(TimeSpan.Fro…
silverlight，在 WCF 调用上使用 Observables，将 IEvent 转换为其中 T : AsyncCompletedEventArgs
我有一个使用 Silverlight 4 中的 Observables 进行 WCF 调用的问题。 考虑下面的简单 Web 服务调用。 var adminclient = ServiceProxy.WithFactory&l…
如何使用 List<> 阻止 ToObservable？
我第一次尝试 RX，有几个问题。 1）有没有更好的方法来完成我的集合的异步？ 2）我需要阻塞线程直到所有异步任务完成，我该怎么做？ class Program { …
我怎样才能从 IObservable 获取历史记录？
我正在通过 Observable 监视股票报价流，我观察它以匹配特定条件，例如 - Observable .Empty<Quote> .Where(q => q.Price > watchPrice) .Sub…
是否有更简单的方法让 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.WriteLine…
如何合并两个 Observables，以便当任何一个 Observables 完成时结果也完成？
我有这样的代码： var s1 = new Subject<Unit>() var s2 = new Subject<Unit>() var ss = s1.Merge(s2).Finally(() => Console.WriteLine("…
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 扩展方法，它返回“流的流”而不是以前的“列表的流”。我在尝试使用新方…
