问题标签 [combinelatest]

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 回答
388 浏览

c# - 如何在 Rx.NET 中为 2 种不同类型使用 CombineLatest

我无法弄清楚将这两个可观察对象、属性ConfigurationBalanceDtosRx.NET 结合起来的语法是什么,可以在 RxJS 中做到这一点没问题(下面的示例),有什么想法吗?这是我能得到的最接近的结果,但它不正确。

所以我想要的是当属性 Configuration observable 更改或 BalanceDto 属性中的任何 observable 更改时,它应该发出该更改

弹珠是:-c1-b1-b2-b3-c2 ---[c1,b1]-[c1,b2]-[c1-b3]-[c2,b3]

使用打字稿中的 RxJS,我会写以下内容:

我只是无法弄清楚 Rx.NET 中相同事物的语法是什么。我查看了 Rx.NET 的其他示例CombineLatest,但它们总是组合相同类型的对象。

0 投票
1 回答
557 浏览

angular - combineLatest 仅针对第一个事件触发

我有 3 个要组合的事件,当其中一个事件被触发时,调用该服务。我用过combineLatest,但只有当第一个事件被filterChanged.

filterChanged是一个本地事件,而其余的是来自子组件的事件。我该如何解决这个问题,以发出其中一个事件,甚至从页面初始化开始?

谢谢

0 投票
0 回答
52 浏览

typescript - 是否可以在没有 forkJoin 或 combineLatest 的情况下访问管道变量?

forkJoin()是否可以访问 RxJs 设备中以前的管道变量combineLatest(),在我的情况下,由于价值积累,没有嵌套管道?

switchMap()或者在以下情况下嵌套管道甚至可以吗?

0 投票
1 回答
234 浏览

javascript - 结合最新。出错后继续观察

我有几个 observable 与 combineLatest组合在一个 observable 中。此外,我还有一个内部switchMap可观察对象,在实际示例中向远程服务器发出 http 请求。

现在我想知道,如果switchMap返回错误,组合的可观察对象如何继续工作?

我在这里创建了简化的示例

输出

所以在得到error combineLatestobservable的工作停止之后。在我的真实示例中,我有 4 个过滤器,在更改过滤器后,我发出 http 请求。

0 投票
1 回答
40 浏览

angular - Property 'combineLatest' doesnt exist on type 'Observable'

Hello I am using RxJS combineLatest operator and getting this error. Could someone let me know what changes I should do

0 投票
1 回答
92 浏览

rxjs - 无限滚动的可观察分页以保持最新

我试图让我的 observable 在分页期间自动更新。

仅页面触发器

load()被调用时,页面可观察对象被触发,但订阅可观察对象在更新时不会被触发......

仅订阅触发器

这里确实触发了订阅更改,但是load()调用时,不会触发页面更改...

当然,有一种方法可以通过页面更改和订阅更改来更新 Observable?

我应该补充一点,重置变量声明this.posts不起作用,因为它刷新了页面并且不是预期的行为。

有任何想法吗?

谢谢,

Ĵ

0 投票
1 回答
55 浏览

swift - Swiftui + Firestore + CombineLatest 持续发布数据

我正在尝试合并来自两个不同集合的查询的两个已发布对象,以使用combineLatest.

当我调试时,我可以看到aListbList发布一次,但是,cList不断发布的内容最终会吃掉所有的内存......

是通过视图中的cListonReceive 语句使用的,该语句输出每个项目。

谁能告诉我为什么combineLatest不断出版cList,虽然没有新鲜aListbList出版?

提前谢谢了。

0 投票
1 回答
149 浏览

rxjs - 组合 combineLatest 和 switchMap 时未定义

我正在尝试将两个 Observable 组合起来,以便为接受两个值的服务调用方法提供很少的值。但在这里我有几个错误

  • '([filter, sort]: [string, string]) => void' 类型的参数不能分配给 '(value: [string, string], index: number) => ObservableInput' 类型的参数。类型“void”不可分配给类型“ObservableInput”。

  • 在控制台中 -

    您在预期流的位置提供了“未定义”。您可以提供 Observable、Promise、Array 或 Iterable。在 subscribeTo (subscribeTo.js:27) 在 innerSubscribe (innerSubscribe.js:71) 在 SwitchMapSubscriber._innerSub (switchMap.js:44) 在 SwitchMapSubscriber._next (switchMap.js:34) 在 SwitchMapSubscriber.next (Subscriber.js:49 ) 在 CombineLatestSubscriber.notifyNext (combineLatest.js:73) 在 InnerSubscriber._next (InnerSubscriber.js:11) 在 InnerSubscriber.next (Subscriber.js:49) 在 BehaviorSubject._subscribe (BehaviorSubject.js:14) 在 BehaviorSubject._trySubscribe ( Observable.js:42)

  1. 定义 Observables 和 Subjects。

  2. 结合可观察的。

  3. 在服务方法中使用合并值。

0 投票
1 回答
46 浏览

angular - 尝试使用 Angular 中的 CombineLatest 将两个可观察的流与键合并

我有两个从 firebase 获得的 observables。这两个 observable 有两个公共变量:一个是 bankAccountId,另一个是 linkTobankAccountId。我需要将这些 observable 合并到一个具有以下结构的对象中:

我没有很多合并可观察对象的经验。我尝试了很多事情,但到目前为止我还没有成功。我在语法上有问题——特别是对我用作键的变量进行“内连接”。这是我的代码:

我意识到语法是错误的。我收到一个错误,它找不到bankAccountId。我不知道如何使它工作。

0 投票
3 回答
225 浏览

angular - Rxjs 扫描不触发 combineLatest

我正在与 combineLatest 和 scan rxjs 运算符(使用 Angular 8)作战。基本上,我正在显示一个可以过滤的列表。

所以我有第一个 Observablelist$ = this.api.getAll()
和第二个Observable filteredList$ = combineLatest(this.list$, this.form.valueChanges())
,在我的 HTML 中,我filteredList$使用filteredList$ | async. 这很好用(意思是,表单中的任何更改都会更新 my filteredList$

但是,最终用户可以更新列表中的一个元素;当他这样做时,我会以这种方式更新我的list$Observable:

这也很有效。
但是,combineLatest不会触发,因此,在我刷新页面之前,我的 UI 永远不会更新。我认为这是因为list$指针没有改变,所以没有理由触发 combineLatest ;但我怎么能强迫它?

顺便说一句,使用 changeDetector 来检测Changes 或 markForCheck 不起作用。