问题标签 [reactive]

最近开始使用 ReactiveUI，到目前为止一切都很好。在尝试找出问题时，我遇到了一个HttpClient / Refit问题。我有一个很长的列表，该列表中的每个项目都必须向 API 发出请求，如下所示。

这是一个反应对象

在 DownloadMultipleCalls 中发生了以下情况。

最后，这行代码出错了var searchResult = await api.GetAvaPerStatusRaw(id);应用程序崩溃并响应“400 Bad Request”，如果我查看错误，它说没有 id 值代替 GET 请求。但是当我检查id 有一个值的初始值时，它不应该对此做出响应。谁能帮我这个？如果您有任何问题，请随时提问。非常感谢。

亲切的问候，

费尔南多

给定用户定义的输入，我想选择数据集的一些行。在这种情况下，我想根据现场的不同位置运行不同的分类树。我在 Shiny R 中有一个 selectInput() ，它扩展了一个菜单，您可以在其中选择要运行树的字段位置。但是，目前它仅适用于所有职位，而不是单独适用于每个职位。我很感激有关如何根据用户选择在数据集之间切换的一些帮助。

服务器.R

我尝试用流星构建一个家庭自动化系统。因此我想做以下事情。

我有一个集合，其中包含我从任何来源读取的所有不同的 liveValues。每个文档都是具有实际值的例如传感器的值。

现在我想创建第二个名为 thing 的集合。在这个集合中，我想添加我所有的“事物”，例如“室温生活”和这个事物的数据。一个属性应该是与 liveValues 之一的连接。

现在我想使用 Meteor 发布和订阅 Thing 集合，因为在 Web 界面上，Thing 背后的 liveValue 无关紧要。

在这里，在我的选项中，复杂的部分开始了。

我如何将数据发布到客户端，并且当 LiveValue 更改为该事物时，我将进行反应性更新？因为它是一个不同于“Thing”集合的集合。

在我的想法中，我想通过一个订阅一个“事物”文档来做到这一点，我将通过这个订阅返回 liveValue 集合的 liveValue 更新。

这可行吗？

有人知道我该如何处理吗？

我听说过有关流星反应发布的一些信息，但我不确定这是否是解决方案。我也听说这需要大量的服务器电源。

谢谢你的帮助。

我正在使用 Interval 运算符，即使我的管道发生异常，我也想继续发出项目。

所以我尝试onErrorResumeNext在出现异常的情况下使用发射项目。但是我看到在发出这个项目之后，间隔停止发出更多的项目。

这是我的单元测试。

我对这种行为感到困惑，为什么 observable 取消订阅，如果它收到来自onErrorResumeNext

解决方案：

经过一些解释，我意识到当发生错误时，可观察到的 t 就完成了。所以我最终将可能有异常的可观察对象包装到另一个可观察对象中，并且我正在使用 flatMap。于是主 Observable 继续发射项目。

如果有任何操作员可以做我想知道的所有魔法。

研究生

我想在Shiny应用程序中实现一个功能。我自己的函数get_calculate()将参数 data 和容差作为输入，并list用 adata.frame和 a 重新运行 a plot。

我想根据公差显示输出。在我的服务器功能中，我reactive()用来运行get_calculate()但它不起作用。

如果我写信renderPlot()并renderDataTable() get_calculate()工作。然而，对于大型数据集，它的效率很低，因为Shiny必须运行get_calculate()两次。

统一 5.4.3f1。

我正在学习使用 UniRx 来定位 Unity 的反应式编程。我试图从输入轴创建一个简单的数据流的那一刻。

我收到此错误：

UniRx 的示例编译得很好。

我看不出两者有太大区别。我错过了什么？

问题：当我在显示和隐藏密码之间切换时，formControlName 'Password' 的输入值没有反映。

流量：

1. 在密码字段中输入一些值。
2. 使用显示密码切换字段
3. 密码字段为空

我的观点部分：

ts部分

提示： http: //blog.ng-book.com/the-ultimate-guide-to-forms-in-angular-2/

提前致谢

我需要从 Shiny 应用程序中的反应式表达式返回一个 cspade() 对象，通过另一个反应式表达式使用它并生成一个 ruleInduction() 对象。代码如下：

当我运行应用程序时，我收到以下错误消息： 错误：找不到对象“规则”

我怀疑反应函数以某种方式以错误的方式返回对象或根本不返回对象。但我不知道如何解决它。

非常感谢任何帮助！

使用https://github.com/neuecc/UniRx，

我有两个可观察的 A 和 B。

我希望 A 被 B 过滤。Sample似乎是我想要的，但它是负面的。

我想要某种类似的伪代码：

（更新1）这是实际代码。我正在尝试用冲突流抵消输入流。

我想我可能会走错方向。

来自RxJava JavaDocs 链接

说：
ReplaySubject：缓冲它观察到的所有项目并将它们重播给任何订阅的观察者的主题。

UnicastSubject：一个主题变体，它缓冲事件直到单个订阅者到达并将它们重播给它，并且一旦订阅者赶上并请求无限量，则可能切换到直接传递。

附言。我在实现两者时得到的区别之一是 UnicastSubject 只能有一个订阅者（证明名称为 Unicast），而 ReplaySubject 可以有很多。