RxJS中如何为mergeMap添加条件以转换嵌套订阅的Observable？

问题原因 #

你原有写法报错的核心原因是*mergeMap高阶操作符强制要求返回一个Observable对象*，你仅在满足条件时返回了Observable，条件不成立时无返回值，因此会抛出类型错误。

正确实现 #

你可以配合RxJS内置的EMPTY空Observable实现条件判断，不满足条件时直接返回EMPTY终止后续流程，同时用tap处理纯副作用操作（变量累加、数据修改等），逻辑更清晰：
首先导入依赖：

import { mergeMap, tap, EMPTY } from 'rxjs';

完整改写代码：

// 初始化计数器
let i = 0;
let h = 0;

observableFunction(par1, par2)
  .pipe(
    // 处理第一层返回值的副作用逻辑
    tap((resp) => {
      i++;
      // 这里写原来的 manipulate resp 逻辑
    }),
    mergeMap((resp) => {
      const lastIteration = someArray.length === i;
      // 满足条件才返回下一层Observable，否则返回EMPTY终止流程
      return lastIteration ? observableFunction(par1a, par2a) : EMPTY;
    }),
    mergeMap((res2) => observableHandleFunction(res2))
  )
  .subscribe((handledData) => {
    h++;
    // 这里写原来的 manipulate handledData 逻辑
    const lastIterationSub = someNestedArray.length === h;
    if (lastIterationSub) {
      console.log("done");
    }
  });

补充说明 #

• EMPTY是RxJS内置的空Observable，不会发射任何值直接进入完成状态，完美匹配你原来if判断的分支逻辑
• 如果你使用的observableFunction是一次性发射完整数组而非逐个发射数组元素，你可以直接去掉计数变量i，直接判断返回数组长度即可，代码可以进一步简化

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