问题标签 [reactive-extensions-js]

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

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

我发现的是

也触发了相同的结果。

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

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

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

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

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

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

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

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

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

http://plnkr.co/edit/NGMB7RkBbpN1ji4mfzih

在我的系统中，我有一个源，两个“步骤”将源映射到一个新值，然后是一个将这两个步骤组合起来以创建最终值的总和。这个系统的初始运行按我希望的那样工作，产生一个 3 的总和。

输出：

但是，如果我为 source 输入一个新值，我会得到如下两个结果：

第一个是中间结果……当新的源值通过系统的一部分时，当所有值都完成传播时，我得到最终结果。

所以我的问题是，推荐的配置方法是什么，以便推入源的新值将原子地通过系统并且只生成一个总和结果？

谢谢！

假设我有一个数组项

我知道我可以使用这个数组创建一个 observable

如何从中创建一个惰性无限重复的可观察对象（即：只要请求它们就重复这些项目）？

试过了

但这不会延迟执行，因此会锁定浏览器。

我很难看到 RxJs 中 switchLatest 和 flatmapLatest 之间的区别，区别在于一个嵌套的 observable 像在 scala 中一样扁平化，而另一个相当于在返回新的扁平化集合之前执行它？

我是不是错过了什么。

如果我使用 $createObservableFunction 方法创建了一个可观察对象，并且我多次订阅该可观察对象。最后一个订阅者覆盖任何其他订阅者。

但是，如果我使用 rx.Observable.interval() 创建一个 observable 并多次订阅它。两个订阅者都在间隔开火。

为什么？更重要的是如何让 $createObservableFunction 触发两个订阅者。

说明问题的示例 plunker。http://plnkr.co/edit/kXa2ol?p=preview

我正在使用 RxJs 来计算在特定时间窗口内到达的数据包数量。我的代码基本上是这样的：

如何使用 Rx TestScheduler 对该代码进行单元测试？我找不到任何适合测试主题的示例。

我试图限制来自公共消息总线的事件应该发送到服务器。允许的事件在outgoingEvents阵列上。问题是要正确地向他们发送我需要事件名称的服务器。

我有一项以页面形式返回数据的服务。对一页的响应包含有关如何查询下一页的详细信息。

我的方法是返回响应数据，然后如果有更多可用页面，则立即将延迟调用连接到相同的可观察序列。

这一定是错误的方法，因为在 2 秒内你会得到：

什么是正确的分页方法？