Angular+RxJS如何合并两个Observable并在二者均有数据时返回true

原方案合理性说明 #

你选择combineLatest的方向完全正确，之前其他操作符失效的核心原因如下：

• forkJoin：需要所有传入的Observable都**主动完成（complete）**才会触发返回，而NgRx的状态流是持久订阅流，默认不会触发complete，因此永远不会返回结果
• merge：任意一个Observable发射值就会触发返回，无法保证两个流都已经产生有效数据
• concat：需要等第一个Observable完成后才会订阅第二个，同样因为NgRx流不会完成，永远拿不到第二个流的结果

combineLatest的触发逻辑刚好匹配你的需求：只有所有传入的Observable都至少发射过一次值时，才会首次触发下游，满足「二者均有数据再返回」的要求。 #

现有写法的可优化点 #

你当前的实现存在两个隐患，建议调整：

1. 判断逻辑不严谨：当前map中仅判断data是否存在，combineLatest返回的是长度为2的数组，只要两个流都发射过值数组就存在，无法校验两个值的有效性，万一上游filter逻辑被误删会出现异常返回
2. 流未主动终止：NgRx状态流是长订阅流，路由守卫只需要在激活判断时取一次值即可，不终止订阅会有内存泄漏风险

优化后代码 #

return combineLatest([materialState$, userCurrency$]).pipe(
  // 只要第一个符合要求的结果就终止订阅，避免内存泄漏
  take(1),
  // 显式校验两个返回值都为真，逻辑更严谨
  map(([hasMaterialState, hasUserCurrency]) => hasMaterialState && hasUserCurrency)
);

内容的提问来源于stack exchange，提问作者ashv9