问题标签 [reactive-extensions-js]

大约两年前，Microsoft Research 有一个很棒的 RXUI-For-Web 原型，它带有一个示例 html 页面，当您移动鼠标时，该页面上的文本“时间像箭头一样飞逝”。我一直在尝试再次找到原型，但 MS Research 已经重新组织了这些页面，我无法再次找到原始示例项目。有谁知道这个转移到哪里了？有谁知道我可以找到原始“时光飞逝”示例的替代位置？

我正在尝试为 .Net 学习新的 Reactive Extensions 框架，这听起来像是我的应用程序的完美解决方案。在研究了示例之后（并且仍然对 LINQ 相当薄弱），我正在努力弄清楚如何利用 RX 框架来完成以下任务。

目标是在自定义数据源和 GUI 之间创建一个可配置的事件“中继”。中继将使用 LINQ 测试和过滤传入的事件，将合格的事件缓存在列表中，同时等待下一个时间间隔，然后同步到 GUI 线程并按照接收到的顺序播放事件。

如何使用 RX 来协调缓存、过滤和中继多个事件，例如添加、更改和删除自定义数据源中的值的事件？

这可能会问很多，但非常感谢任何有关如何解决此问题的指导。请参阅下面的示例代码...

鉴于所描述的任务，我不确定在一般类代码中应该协调什么，以及应该在 RX 语句中隐藏什么。

我也很欣赏这样一个事实，将 3 个事件组合成一个事件并通过一个指示事件目的的枚举来大大简化事情，但是在实际应用程序中缓存的不仅仅是 3 个事件。我不希望必须使用常量 Switch 语句测试来识别每个事件的开销。将有大量事件路由到潜在的众多 GUI 界面。

感谢您的任何建议。

github 上的 fromArray Rx wiki

看起来该subscribe函数在创建时只会触发一次。看起来这有点用词不当，因为我实际上只是在为数组而不是观察它的变化。不过，该代码几乎与 wiki 上的代码完全相同。所以要么我做错了，要么subscribe没有按照我的预期工作。

我正在编写这个 Web 应用程序，我需要通过 JavaScript 可视化过滤、排序和分页（在服务器上）的集合（计划使用Isotope来呈现集合）。这些集合是动态的，即它们从某些项目开始，但它们的内容可能会在整个应用程序的生命周期内发生变化。我可以通过 Reactive Extensions for JavaScript 观看服务器上的集合来实现此功能吗？如果是这样，怎么做？

例子

对于这个特定问题，假设一个集合在 HTML 中呈现为一个元素，每个集合项都有#container一个 class 的子元素：item

如果“Item 2”随后被添加到集合中，并且“Item 1”在服务器上从中删除，JavaScript 应该通过将更新的集合呈现为 HTML 来做出反应，如下所示：

我创建了一个动画小提琴来演示这种场景。想象一下，对集合的更改发生在服务器上，而 JavaScript 只是对其作出反应。

很长一段时间以来，我都在尝试围绕 RX。而且，说实话，我永远不确定我是否得到它 - 或者没有。

今天，我在http://reactive-extensions.github.com/RxJS/上找到了一个解释——在我看来——这太可怕了。它说：

RxJS 之于事件就像 Promise 之于异步。

伟大的。这是一个非常复杂的句子，如果你对 RX 是什么一无所知，那么在这句话之后你就和以前一样愚蠢。

这基本上是我的问题：你在通常的地方找到的关于 RX 的所有解释都让（至少我）觉得很愚蠢。他们将 RX 解释为一个高度复杂的概念，其中包含许多高度复杂的单词和术语等等，我永远不太确定它是关于什么的。

所以我的问题是：你会如何向五岁的人解释 RX？我想要对它是什么、它有什么用处以及它的主要概念有什么清晰、生动的解释？

在请求对响应式扩展 (RX) 进行清晰、如画的解释？我询问了 RX 的全部内容，我想，感谢提供的答案，我现在明白了。

在引用的问题中，我引用了http://reactive-extensions.github.com/RxJS/中的一句话：

RxJS 之于事件就像 Promise 之于异步。

虽然我认为我得到了 RX 背后的想法，但我完全没有得到这句话。我什至不能说我不明白的到底是什么。这更像是......我没有看到句子的前半部分和后半部分之间的联系。

对我来说，这句话听起来很重要，很感人，但我很难判断它是否真实，是否是一个伟大的见解，等等......

任何人都可以用某人（比如我）可以理解谁是所有这些反应性东西的新手来解释这句话的含义吗？

我只是想实现

https://github.com/Reactive-Extensions/RxJS

到我的节点项目。

当然，有可用的 npm-package，但我看到它更新较少，模块较少，并且只使用了 min. 文件，所以我想使用来自 git 源的 rxjs。

我下载了 RxJS-master 并将目录下的整个文件复制到 ../myProject/lib/rx/

我懂了

这些文件中的rx.node.js

所以，我的 app.js代码是这样的

这会产生如下错误，

怎么了？

如果我将 rx.node.js修改为

代码按预期工作，因此显然require - sub modules部分进展不顺利。

谢谢。

我使用 Rx.js 和 JqueryPromises 我遇到了一种情况，我调用一个方法来处理由 Rx 发布的事件。但是，此方法返回一个承诺。

问题是事件的处理不再是确定性的。由于 methodThatReturnsPromise 在延迟处理时立即返回。

我的问题:) 有没有办法“等待”承诺？Rx 是否有任何钩子来使用承诺，即将返回的订阅承诺链接到下一个返回的订阅承诺，所以消息仍然按顺序处理？

我试图弄清楚 RxJS 中的任何现有运算符是否可以实现以下操作，或者我是否需要推出自己的扩展：

最好的，埃吉尔。

我发现了这个关于如何让 SignalR 和 Rx 正常运行的小宝石：

Rx 和反应式教程

但是，您可能已经注意到，这只适用于从服务器 -> 客户端。有谁知道如何反过来？我希望我的框架更像是基于 NServiceBus 的“消息”和更少的 RPC（信号器标准示例往往是）。

原因是弱类型世界不适合 RPC。在服务器端，我希望能够在客户端调用周围放置接口，但我不能，因为客户端甚至可能不是 OO 并且没有合同和接口的概念。

所以我希望把所有东西都变成基于消息的，中间是通过响应式 SOA 服务的代理。希望 Reactive 和 DTO 将是我代码中的唯一依赖项。

那么有谁知道如何实现这一点？