问题标签 [reactive-programming]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
601 浏览

c# - 如何使用 Throttle 过滤事件

我正在尝试以胜利形式使用反应式框架。

我想过滤 mouseDrags,只需要在 MouseDowns 之后超过 1 秒的 MouseUps。如何?

0 投票
1 回答
619 浏览

haskell - 为什么这个 Yampa 弹球会陷入死循环?

我正在尝试使用 Yampa 框架模拟弹跳球:给定初始 x 位置、高度和速度,球应该根据重力规则弹跳。信号函数将“Tip-Event”作为输入,其想法是“当球被倾斜时,它的速度应该加倍”。

球弹得很好,但每次发生翻倒事件时,该函数都会进入无限循环。我想我可能需要添加一个延迟(dSwitch,pre,notYet?),但我不知道怎么做。任何帮助,将不胜感激!

编辑:我设法通过在发生小费时反馈一个标志来避免无限循环,但这仍然不是正确的做法......

0 投票
4 回答
276 浏览

wcf-ria-services - RIA 服务匹配请求的响应

我想知道是否有人可以就以下问题提供一些建议。我们目前正在开发基于 RIA .NET 服务的 Silverlight 4 应用程序。应用程序中的一个屏幕允许用户输入搜索字符串,并且在 2 秒不活动后,请求被提交到我们的域服务。这一切都与 Rx 很好地处理。

现在,目前可以在原始搜索返回之前执行第二次搜索。第二个请求也有可能在第一个请求之前返回。

真的,我只是想找出人们用来管理对正确请求的正确响应的模式和方法。

您是否在请求中使用了某种操作标识符?您是否为每个请求创建域服务的新实例?是否可以将请求的完成事件与监视 textchange 事件的 Rx 可观察对象联系起来?

任何指导都会很有帮助,

戴夫

0 投票
3 回答
1179 浏览

c# - Observable.Delay 在 OnNext 被触发之前调用 Dispose

我在理解 Observable.Delay 的工作原理以及何时调用 Dispose() 时遇到问题。熟悉 Rx 的人可以帮忙吗?

以下代码片段:

产生以下结果:

0
1
已处置
已处置 已
处置
...0...
...1...
......0......
......1......

我期待它更像:

0
1
弃置
...0...
...1...
弃置
......0......
......1......
弃置

任何想法??

0 投票
2 回答
1846 浏览

.net - 在 Rx 中聚合 ForkJoin 的结果

鉴于这段代码:

如您所见,问题在于每个FindBooksAsObservable()方法都返回一个IObservable<IEnumerable<Book>>,因此Subscribe()中的结果变量是一个 数组。IEnumerable<Book>

有没有其他方法可以聚合ForkJoin()的结果?我希望将Merge()之类的东西与 ForkJoin 一起使用。

0 投票
1 回答
607 浏览

clojure - 使用 Clojure Cells 或 add-watcher 进行反应式程序?

我想在我的 clojure 程序中使用很多反应式(数据流)类型的编程技术。在 clojure refs 上使用“add-watcher”将足以做到这一点。一个简单的例子是在底层数据发生变化时更新 GUI。

0 投票
2 回答
2704 浏览

c# - 使用响应式扩展 (Rx) 延迟和重复数据删除

我想使用响应式扩展来转换一些消息并在一小段延迟后中继它们。

消息如下所示:

输出看起来像这样:

有几个要求:

  • 延迟的长度取决于消息的内容。
  • 每条消息都有一个 GroupId
  • 如果新消息与等待传输的延迟消息具有相同的 GroupId,则应丢弃第一条消息,在新的延迟期后仅传输第二条消息。

给定一个 Observable<InMsg> 和一个 Send 函数:

我知道我可以使用 Select 来执行转换。

  • 如何应用消息指定延迟?(请注意,这可能/应该导致消息的无序传递。)
  • 如何对具有相同 GroupId 的消息进行重复数据删除?
  • Rx 有能力解决这个问题吗?
  • 有没有其他方法可以解决这个问题?
0 投票
4 回答
136 浏览

programming-languages - “主动表达式”的编程语言或库

我正在寻找提供 Excel 公式意义上的“活动表达式”的编程语言、库或框架,其中修改实体的值将导致重新计算引用所述实体的所有表达式,从而可能引发进一步的重新计算。

我可以想象,使用这样的库或语言将简化我们的应用程序(空中交通显示)的实施和维护,这些应用程序基本上根据某些规则可视化传入的数据。

谁能提供参考?

亲切的问候,
塞巴斯蒂安

0 投票
2 回答
10187 浏览

knockout.js - Knockout.js 和 Rx.js 有什么区别?

有谁知道RxJsKnockout之间的区别?在我看来,他们似乎在尝试解决同样的问题,构建一个事件驱动的 UI。但是,对于两者都有经验的人,它们有何不同/有何相似之处?你能描述一些关于他们的事情来帮助我选择吗?

0 投票
2 回答
1015 浏览

system.reactive - 反应式框架/DoubleClick

我知道有一个简单的方法可以做到这一点 - 但今晚它打败了我......

我想知道两个事件是否在 300 毫秒内发生,例如双击。

在 300 毫秒内单击鼠标左键两次 - 我知道这是构建反应式框架的目的 - 但该死的,如果我能找到一个很好的文档,其中包含所有扩展运算符的简单示例 - Throttle、BufferWithCount、BufferWithTime - 所有这些都没有'为我做这件事......