使用combineLatest时如何让订阅回调仅执行一次，不可用forkJoin、zip

要在保留combineLatest的前提下让订阅回调只触发一次，最简洁的方案是搭配RxJS原生的take(1)操作符，无需引入外部状态标记：

import { take } from 'rxjs/operators';

combineLatest([obs1, obs2, obs3])
  .pipe(take(1))
  .subscribe(([s1, s2, s3]: any) => { 
    openModal();
  });

实现原理 #

combineLatest的默认逻辑是：所有传入的Observable都至少发出过1次值后，任意源发出新值就会输出新的组合值。而take(1)会在接收到第一次组合值后直接终止整个数据流，自动取消订阅，后续所有源的更新都不会再触发订阅回调，完全匹配需求。相比外部flag标记方案，这个实现没有外部副作用，状态完全封装在流内部，不会出现变量被意外修改导致的逻辑异常，可维护性更高。

扩展场景：满足条件的首次触发 #

如果需要三个值符合特定规则时才触发弹窗，可以在take(1)前追加filter操作符做前置校验：

import { take, filter } from 'rxjs/operators';

combineLatest([obs1, obs2, obs3])
  .pipe(
    // 示例规则：三个值都不为空时才生效
    filter(([s1, s2, s3]) => !!s1 && !!s2 && !!s3),
    take(1)
  )
  .subscribe(([s1, s2, s3]: any) => { 
    openModal();
  });

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