问题标签 [rxjs]

给定：响应式扩展拖放示例，您将如何仅订阅 drop 事件？

我已修改代码以订阅“已完成”回调，但未完成。

我读过热的可观察对象，例如从鼠标事件创建的那些，永远不会“完成”。它是否正确？我怎样才能在“drop”时获得回调？

在 Rx JS 的表面上，我得到了以下代码片段：

输出：下一个：1 已完成

JS BIN 代码参考：http: //goo.gl/DiHdWu

为两个流订阅同一个观察者只会从第一个流中产生数据。但是，当订阅其他观察者时，事情会按预期进行。有人可以解释发生了什么吗？

输出：下一个：1 已完成 下一个：2 已完成

我想知道编写一个 Observable 序列的最优雅的方法是什么，它每次都会产生任意数量的新计算结果。我想出了以下内容：

这将在订阅时创建 2000 个新的随机值。这解决了它，但它并不优雅。我更喜欢基于take而不是重复的解决方案。

我试图在 RxJava 中找到 Observable 运算符，它将执行以下过滤器：

我可以构建一些东西，但我认为标准库中一定有我忽略的东西。

distinct不起作用，因为它只返回0 5 1.

是否可以将单个可观察通量拆分为多个其他可观察通量？

我的用例是用户可以提交的表单。提交动作在一个可观察对象中处理，在这个动作上，有一个验证器在监听。

问题是我想将操作绑定到验证器检查的success或failure。

我不确定在反应式编程中如何处理类似的情况 - 可能拆分 observable 并不是处理此类问题的正确解决方案。

无论如何，您将如何处理类似的情况？

伙计们，我有一个使用 RxJS 处理鼠标事件的应用程序。我将这些事件组合成更复杂的可观察“手势”。一种这样的手势是“摇晃”。

我试图撰写的一系列事件是：

我发现的是

也触发了相同的结果。

我在 codepen 上演示了这个问题。

我的一般问题是：你如何在 RxJS 中表达一个 observable，例如 mouseup，应该取消并重新启动 observable 的组合？

作为问题的另一个示例（来自同一个小提琴），以下事件

导致 3 次摇晃事件。我希望它产生一个。

如果我有一个事件类型；说一个点击事件。我想触发 3 个唯一的 ajax 请求，但我想订阅所有 3 个请求的最终结果

这个序列的正确设计模式是什么。

我当前的代码块看起来像这样

当内部可观察错误（Ajax 请求）时，RxJs 停止监听点击事件。我试图弄清楚如何让事件侦听器连接到按钮单击事件并优雅地处理内部 ajax 错误。

这是我的示例代码和 plunkr 的链接

http://plnkr.co/edit/NGMB7RkBbpN1ji4mfzih

我有一个返回承诺的函数。
我想使用 rx.js 订阅该承诺，调用此函数会将通知推送给所有订阅者。

这是我所拥有的：

结果，订阅者只收到一个通知。

如何解决？

有人可以给出一个清晰的定义和一个简单的例子来解释什么是不了解 JavaScript 和 node.js 的人的“回调地狱”吗？

“回调地狱问题”何时（在什么样的设置中）发生？

为什么会发生？

“回调地狱”总是与异步计算有关吗？

或者“回调地狱”也可以在单线程应用程序中发生？

我参加了 Coursera 的反应式课程，Erik Meijer 在他的一次讲座中说 RX 解决了“回调地狱”的问题。我在 Coursera 论坛上问过什么是“回调地狱”，但没有得到明确的答案。

在用一个简单的例子解释了“回调地狱”之后，你能否在这个简单的例子中展示 RX 是如何解决“回调地狱问题”的？