Observable.Create from Boo 的类型问题
我正在尝试使用 Boo 的反应式扩展，但遇到了类型问题。这是基本示例： def OnSubscribe(observer as IObservable[of string]) as callable: print "su…
使用 Rx 对 Bing 地图中的地址进行地理编码
我正在学习如何使用我正在开发的 Silverlight 4 应用程序的 Rx 扩展。我创建了一个示例应用程序来确定该过程，但我无法让它返回任何内容。 这是主要代…
响应式：将合并的 IObservable 转换为一个行为类似于BehaviourSubject 的流
这是我的示例代码... var rootSubject = new Subject(); var firstSubject = rootSubject.Where(x => x == Types.First); var secondSubject = rootSu…
BufferWithTime 行为不一致
我有一个测试 BufferWithTime 的单元测试。当缓冲将发出新值时发出值时，我似乎得到不一致的结果。 var scheduler = new TestScheduler(); var source…
使用 .NET 反应式扩展时保留对“IDisposable”的引用：始终、从不还是有时？
到目前为止，我一直热心地保留对从任何 .Subscribe(...)、.Connect(...) 返回的 IDisposable 的每个引用> 等 Rx 中的方法。我这样做是因为我担心如果…
Reactive：IObservable 接收到的最新值
我知道以下是阻塞调用，并将返回可观察序列中的第一个值： var result = myObservable.First(); 根据我使用的主题类型，这会产生不同的含义： 主题 - …
IObservable - 如何发送/发布/推送新值到集合
我想从我的服务层公开 IObservable。 为了简单起见，我们假设服务层在内部从远程服务器（通过套接字）获取消息，并且套接字库需要一个 IMessageRepons…
如何使用 Rx 和 F# 将 WPF Button.Click 事件转换为 Observable
我正在尝试复制一些从 Button.Click 事件创建 IObservable 的 C# 代码。 我想将此代码移植到 F#。 这是编译时没有错误的原始 C# 代码： Observable.Fr…
为什么 Rx Observable.Subscribe 会阻塞我的线程？
你好，我已经尝试了 101 Rx 示例之一： static IEnumerable GenerateAlternatingFastAndSlowEvents() { int i = 0; while (true) { if (i > 1000) { y…
如何在需要的 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()…
如何使用 List<> 阻止 ToObservable？
我第一次尝试 RX，有几个问题。 1）有没有更好的方法来完成我的集合的异步？ 2）我需要阻塞线程直到所有异步任务完成，我该怎么做？ class Program { …
