RxJS中如何在某一流未发射值的场景下获取所有流的变更数据？

解决方案 #

你可以通过哨兵占位符+过滤初始值的方式实现需求，既绕开了combineLatest需要所有流至少发射一次的限制，也完全符合「仅用户主动触发变更才生效」的要求，改造步骤如下：

1. 为无默认值的textPropsChanges$添加一个独一无二的哨兵值作为初始占位，该值仅用于内部逻辑判断，不会实际进入存储逻辑

// 声明唯一哨兵值，避免和实际业务值冲突
const NO_TEXT_CHANGE = Symbol('NO_TEXT_CHANGE');
const textPropsWithSentinel$ = this.textPropsChanges$.pipe(
  startWith(NO_TEXT_CHANGE)
);

2. 改造combineLatest逻辑，原有防抖、映射逻辑保持不变，仅需适配哨兵值的处理：

this.changes$ = combineLatest([
  this.reportChanges$,
  this.objectPropChanges$,
  textPropsWithSentinel$
]).pipe(
  debounceTime(this.debouncetime),
  // 原有skip(1)逻辑会直接过滤掉三个流全为初始值的首次发射，不会触发存储
  skip(1),
  map(([reportProperties, reportObjectsProperties, textProperties]) => {
    return {
      reportObjectsProperties,
      reportProperties,
      // 哨兵值代表用户未触发过文本变更，按需返回undefined/忽略该字段即可
      textProperties: textProperties === NO_TEXT_CHANGE ? undefined : textProperties
    };
  })
);

3. 后续存储逻辑不需要做任何改动，完全复用你原有逻辑即可。

逻辑说明 #

• 首次combineLatest触发时，三个值分别为前两个流的默认值、哨兵值，会被skip(1)直接过滤，不会触发存储，完全符合你不能用默认值生效的要求
• 任意流被用户主动触发变更时，combineLatest会发射新值：
  • 若用户还未触发过文本变更，textProperties会返回undefined，你可以根据接口要求调整为不传该字段或者其他默认业务值
  • 若用户已经触发过文本变更，textProperties会返回最新的文本属性值
• 原有防抖、多变更合并的逻辑完全保留，不需要调整。

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