我如何才能实现 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<char> keyPresses = ... // a sequence of…
窗口操作符不能与自身一起工作?
我有一些代码希望以某种方式工作,但事实并非如此,我想知道我做错了什么: class Program { static void Main(string[] args) { var ints = Observab…
各种 ISubject 实现的作用是什么以及何时使用它们?
我非常清楚Subject类的作用以及何时使用它,但我刚刚浏览了msdn上的语言参考,发现还有各种其他ISubject实现,例如: AsyncSubject BehaviorSubject R…
使用 .NET Reactive 将延续链接在一起
新手 Rx 问题。我想编写如下方法: public IObsevable<Unit> Save(object obj) { var saveFunc = Observable.FromAsyncPattern(...) saveFunc(obj…
在 Silverlight 中使用 Rx 进行 WCF 调用不适用于 TakeUntil
我有以下代码来设置我的 Rx 连接: 事件相关定义: public class QueryEventArgs : EventArgs { public SomeParametersType SomeParameters { get set…
使用反应性扩展 (Rx) 进行延迟和重复数据删除
我想使用反应式扩展来转换一些消息并在小延迟后中继它们。 消息看起来像这样: class InMsg { int GroupId { get set } int Delay { get set } string…
反应式扩展中带有节流阀的跨线程异常
我正在使用反应式扩展来验证文本框输入。 我正在尝试使用 .Throttle(TimeSpan.FromMilliseconds(500))。 但是,当我添加 .Throttle() 方法时,在 .Sub…
仅在 Visual Studio 2010 中调试期间,简单的 Rx 代码在 Windows 窗体中默默失败
感觉最近 bug 和问题吸引了我! =P 所以我今天终于花了一些时间来探索一些 Rx。 这是我所做的: 这是唯一一段正在运行的代码: private void button1_…
获取用户输入期间的最后 3 个字符
当用户在 richTextbox 中写入一些文本时,我需要从 richTextBox 获取最后三个字符。 我将属性绑定到扩展 WPF 工具包的 richTextBox 的 Text 属性上。 …
在用户输入期间将文本转换为带有微笑的文本
我尝试解决这个问题。我有可绑定的文本和文档属性的 richTextBox,该控件派生自扩展 WPF 工具包的 richTextBox。 我的场景是:用户正在向 richTextBox…