问题标签 [reactive]

我有一个发送事件的可观察流：

我想将此流包装到另一个流中，如果在最后 N 秒内没有事件，则每 N 秒添加一次“请保持”事件：

期望的结果：（X 是新注入的事件

我正在尝试以惯用的反应方式对其进行建模，但还没有找到可以让我轻松做到这一点的运算符。超时是似乎即将结束的那个，除了它不重复，它实际上终止了流。

我在RxSwift中看到了一些代码，但我不明白为什么需要concat(Observable.never())

我有一个eventReactive加载两个数据集的函数。可以选择每个数据集，但它们都加载在同一个eventReactive. 但是，如果用户只更改两个数据集之一，我不希望它们都加载，而只加载已更改的那个。我知道使用两个操作按钮会更容易，但我需要将它合二为一。请在下面找到示例代码。

因此，在示例中，我只想再次执行变量已更改的那部分代码。ui.r:

服务器.r

我已经尝试过这样的事情：if(datasetInput()$input1 != input$dataset){execute...} 但它不起作用，可能是因为您在同一个函数中创建的反应函数中使用了一个值......

我了解反应值会根据此处的描述通知依赖于该值的任何反应函数

基于此，我想利用这个属性并创建一个 for 循环，为我的反应值对象分配不同的值，反过来我期望另一个反应函数重新执行自身，因为反应值在 for 循环内发生变化. 下面是我正在尝试做的一个简化示例：

这是ui.R

这是服务器文件：

这没有给出预期的结果。实际上，当我检查它的内容时，values$a 它是空的。请帮忙！

我正在尝试使用 escher 来构建 UI。我正在从 UI 收集输入，输入通过 map 函数传递给我的 Julia 程序：output = map(function, input1, input2)

该函数返回一个array(Float64,1). 当我在 UI 中可视化时，我得到以下信息：4-element Array{Float64,1}: 3.43632e5 3.63805e5 3.69266e5 3.71911e5 我试图一次可视化一个元素，但我不断收到错误。它是我不能使用的output[index]。

当我应用枚举（输出）时，我得到以下信息：

Enumerate{Reactive.Signal{Array{Float64,1}}}(Signal{Array{Float64,1}}([343631.7211352585,363804.7393436705,369265.5843143601,371910.53794551373], nactions=0))

有谁知道如何可视化输出的元素。抱歉，这对您来说可能很明显，但我一直在寻找，但没有找到任何东西。

我对自己的方法有些怀疑。我有两种类型的 Observable：

我想做一个 Observable，它首先获取所有房屋，然后获取家庭。我所做的是这样的：

但这对于……对我来说似乎不是反应式风格，而且这似乎是一种 hack，因为我对 rx 运算符了解不足。

您在 rxworld 中有正确的方法吗？

谢谢

我收到一个 HTTP 响应，如果一切顺利，它包含一个数组，编码为 JSON。
我想得到这个数组，过滤掉一些项目，并将传递的项目作为事件处理。

到目前为止我所做的是：

但是我不喜欢嵌套。我认为有一种方法可以做到这一点：

如何做到这一点？

我有一个可观察到的事件流，这些事件在一个事件上终止。但是，一旦终止，我需要从头开始重新开始流。流的表示如下：

处理这种情况的好方法是什么？

我正在使用 RxJS。所以我遇到了 child forkjoin() 的问题。如果你有这方面的经验。请给我你的想法

我看到父forkjoin在孩子之前完成

谢谢南

我是 Coursera 上 SCALA 课程的 EPFL 函数式编程的当前学生。通过 sbt 提交作业，我成功通过了第一门课程，直到现在都没有问题。

当我尝试使用生成的令牌提交“计算器”分配时，我收到错误消息，例如

将当前项目设置为 src（在构建文件中：/C:/Users/user/Desktop/cousera%20class/calculator/calculator/src/）

提交 [错误] 不是有效的命令：提交（类似：设置）[错误] 不是有效的项目 ID：提交 [错误] 预期的“：”（如果选择配置）[错误] 不是有效的键：提交 [错误]提交

请问过去谁遇到过这个挑战？我需要帮助