在RxJS中如何链式调用数量不固定的多个Observables？

数据老陈

2026-9-25

解决方案

你这个动态次数链式调用的场景，直接用RxJS内置的expand操作符就能实现，它专门处理递归生成Observable的需求，完全可以替代你现在的嵌套订阅写法，通用性也足够。

基础实现（只取最终查询结果）

首先导入所需依赖：

import { EMPTY } from 'rxjs';
import { expand, last } from 'rxjs/operators';

业务调用代码：

// 替换为你第一次调用需要传入的初始parent_id
const initialParentId = '你的初始父节点ID';

this.myService.getNodeById(initialParentId).pipe(
  // 接收上一次请求的返回结果，判断是否需要继续调用
  expand(res => {
    // parent_id存在就继续发起查询，否则返回EMPTY终止递归
    return res.parent_id ? this.myService.getNodeById(res.parent_id) : EMPTY;
  }),
  // 只保留递归终止后最后一次请求的结果，不需要的话可以去掉这行
  last()
).subscribe(finalNode => {
  // 这里拿到的就是递归到没有parent_id的最终节点
  console.log('最终查询结果：', finalNode);
});

扩展实现（收集所有查询到的节点）

如果你需要拿到每次递归查询的所有节点，只需要把last操作符换成toArray即可：

import { EMPTY } from 'rxjs';
import { expand, toArray } from 'rxjs/operators';

this.myService.getNodeById(initialParentId).pipe(
  expand(res => res.parent_id ? this.myService.getNodeById(res.parent_id) : EMPTY),
  toArray()
).subscribe(allNodes => {
  // allNodes为按调用顺序排列的所有节点数组
  console.log('所有查询到的节点：', allNodes);
});