问题标签 [combinelatest]

在 combineLatest 中，只有当我们将“.subscribe()”应用到其末尾时，才会调用该方法。我想知道除了添加 subscribe 到 combineLatest 方法之外是否还有其他选择。

我如何为异步管道（启用）编写 Jasmine 单元测试用例？我尝试了以下方式

我想将列表的 IObservables 存储在一个容器中，并订阅这些 observables 的组合以检索合并的列表。然后我希望能够添加更多的 Observables 而无需续订订阅并仍然获得新的结果。理想情况下，它也应该在将新的 observable 添加到 store 时触发。下面的代码应该解释更多：

虽然示例是用 C# 编写的，但它最终需要在 rxCpp 中实现。此外，在其他 Rx 变体中看到实现也会很有趣。

我已经设置了一个存储库来检查代码，并且可能会将其扩展到其他语言： https ://gitlab.com/dwaldorf/rx-examples

BR，丹尼尔

我正在使用 RxJava combineLatest 运算符。

根据文档，在订阅时，第一个 combine emit 事件只会在两个 observable 发出值之后发生，并且从这一点开始，它会在每个 Observable 的每次发出时发出。

我如何确定第一个可观察的发射事件已经发生，它现在等待第二个..

我编写了如下的小演示代码。我制作了两个不同类型的 PublishSubject。当我更改任何页面触发器时，我只需要在一个更改时获取页面触发器，哪个observable_page。

我读了一些选项，觉得过滤器或忽略可能在这里有用，但是因为我需要它们的价值，所以很困惑，如何正确应用它。

Let say I have observables A, B, C. I have to listen to change of these three and alter a caculation.

i.e., On value change on any one of the obseravable, I need to recalculate with the new value from the present and the old value for the rest of the observables.

I tried to use combineLatest, which was perfect except the first behavior that all the observables should have a latest/change in the value.

我有以下代码在 rxjs 5 中编译时没有错误：

当我更新到 rxjs 6 时，会发生以下错误：

此外，如果我将 X 或 Y 类型更改为 any 类型，错误就会消失。

据我了解，Swift 不支持匿名类。

我正在使用 RXSwift 代码库，有一段代码我无法完全掌握发生了什么。

这是块：

我遇到的问题是将 combineLatest 转换为此的块，看起来像匿名类。

当我查看 combineLatest 的签名时，它显示：

因此，当我阅读它时，@escaping 关闭通过@escaping (O1.E, O2.E, O3.E)

似乎正在创建一个新的匿名对象，它有 4 个参数而不是 3 个。

您能否解释一下如何创建一个看似匿名的类（我不完全理解为可能）的新可观察对象，并使用 4 个参数而不是 3 个参数创建？

我无法启动我的getData函数app.component.ts来返回包含 API 请求的所有参数的查询。我没有收到任何错误，我也不能console.log在函数内部，因为它不起作用。它会跳过我在里面写的所有内容getData。有任何想法吗？

app.component.ts

过滤器组件.ts

过滤器.component.html

app.component.html

我的组件.ts

数据.service.service.ts

app.component.html

app.spec.ts

静态数据模拟.ts

我添加了我的测试用例来覆盖 app.spec.ts 中的 combineLatest 运算符 anf filterData，但所需的代码失败了。我期望调用 filterData 失败了。combineLatest 将在 valueChange 上触发事件并从 API 获取数据。我可以在规范文件中创建模拟和 setValue，但它仍然无法正常工作。