问题标签 [system.reactive]

反应式扩展（对于 .NET 或 JavaScript）的杀手锏是什么？为什么开发人员应该学习和使用它们？

使用 Rx，有没有一种简单的方法来创建一个单一的Notification<T>？

我能找到的最接近的是：

这似乎相当迂回。的构造函数Notification<T>无法访问，但是有没有我不知道的工厂方法？

Microsoft 使用 .NET Framework 4 引入了BCLIObservable<T>接口，我想，“太好了，终于，我必须使用它！” 所以我深入挖掘并阅读了帖子和文档，甚至实现了这个模式。

这样做之后，我意识到基本实现实际上将所有T事件发送给它的所有订阅者，而没有对其进行任何过滤；即普通广播。我在某处读到 Observable 模式适用于普通广播。我觉得这不是真的，我错过了一些东西。

我的问题：

1. 如果我添加一个过滤机制，那么使用 Observable 模式和只使用普通 CLR 事件有什么区别？

2. 什么时候应该使用这种模式，什么时候应该选择使用普通的 CLR 事件？

3. Observable 模式的主要优点是什么？

隐约记得很久以前看到过一些关于这个的讨论，但从那以后就再也没有听到过任何消息。所以基本上你可以在远程机器上订阅一个 IObservable 吗？

我想有效地限制事件流，以便在收到第一个事件时调用我的委托，但如果收到后续事件则不调用 1 秒。在超时（1 秒）到期后，如果收到后续事件，我希望调用我的代表。

有没有使用 Reactive Extensions 的简单方法来做到这一点？

示例代码：

电流输出：

但我想观察（时间戳显然会改变）

所以我只是在玩RX并学习它。我开始玩事件，想知道如何订阅事件，并异步处理结果。请允许我用代码解释：

引发事件的简单类：

然后我的主要：

正如您在我的评论中看到的，当您像这样调用 subscribe 时，所有订阅代码都会同步发生。每当有新的一批事件要处理时，是否有一种开箱即用的方法使用 RX 在不同的线程上调用订阅？

随着时间的推移，我正在尝试改进我的观察者中的过滤器，我想知道他们最好的方法是什么。

例如myObservable.Where(x=>x.Color=="red").Subscribe();

接着myObservable.Where(x=>x.Color=="blue").Subscribe();

然后将两者合并为一个流，以便OnNext()在 Red OR Blue observables 上调用。

也许它还没有完全了解我正在发生的事情。

如果我也有myObservable.Where(x=>x.Type=="Car").Subscribe();. 每次都会继续调用相同的 OnNext() 方法吗？这对我有什么用.. 我可能想根据哪个订阅调用更新做出不同的反应，但同时我可能想扁平化订阅。

例如在上面的场景中，如果颜色是红色我想写'new red object'，如果它是一辆车我想写'new car'。我将如何在 Rx 中执行此操作？OnNext、OnError 等的订阅有过载。但这要求观察者也是可观察的（主题）。如果我错了，请纠正我。

这对我来说毫无意义..为什么观察变化的东西也应该是可观察的？

我安装了 VS2010 RTM，我想添加对 Reactive Framework 的引用，我已经寻找 system.CoreEx 和 system.Reactive 并且它们不存在。我究竟做错了什么？

这是一个介绍反应式框架的简单程序。但我想尝试错误处理程序，将程序修改为：

在此示例中，使用了以下重载。

我希望我会看到打印的异常消息，但是控制台应用程序崩溃了。是什么原因？

我收到此警告，但找不到对上述程序集的明确引用。

Google 告诉我这与Reactive Framework有关，并且此博客条目表明问题与捆绑 1.0.0.0 的 Silverlight Toolkit 的早期版本有关

有谁知道如何摆脱这个警告？也许我应该删除 Silverlight Toolkit，然后安装当前版本？或者可能我应该获取工具包源并减少参考版本特定？