Angular项目中RxJS combineLatest处理非空值的最优方案咨询

你的实现方案是完全合理的，刚好匹配你的需求：

1. combineLatest会等待每个selector流至少发射一次值，之后只要任意selector更新就会发射最新的组合值；
2. first(list => list.every(item => item != null))会筛选出第一次所有值都非空的组合，然后立即终止流，完美避免后续selector变化导致重复触发API请求。

关于RxJS内置算子的替代写法 #

你当前的写法已经很简洁，不过可以把逻辑拆分为filter+first()的组合，可读性会稍好一点，效果完全一致：

const selectorA$ = this.store.select(...)
const selectorB$ = this.store.select(...)
const selectorC$ = this.store.select(...)

return combineLatest([selectorA$, selectorB$, selectorC$]).pipe(
  filter(values => values.every(val => val != null)),
  first(),
  map(([a, b, c]) => {
    // 生成查询字符串逻辑
    return `?a=${a}&b=${b}&c=${c}`;
  })
)

需要注意的是，不要用forkJoin——它要求每个源Observable必须完成才能发射组合值，但store.select()返回的是永远不会自动完成的流，会导致forkJoin一直处于等待状态，永远不会发射数据。

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