如何用RxJS更优雅地合并两个Observable数据生成富化数据集？

我发起了两个GET请求，返回数据如下：

婚姻数据接口返回 #

[{
  id: 1,
  hId: 2
}, {
  id: 6,
  hId: 1
}]

人员数据接口返回 #

[{
  id: 1,
  name: 'Bob'
}, {
  id: 2,
  name: 'Billy'
}, {
  id: 6,
  name: 'John'
}]

我需要通过RxJS的Observable实现如下富化后的人员数据集：

[{
  id: 1,
  name: 'Bob',
  married: true // 存在hId等于该id的婚姻记录
}, {
  id: 2,
  name: 'Billy',
  married: true // 存在hId等于该id的婚姻记录
}, {
  id: 6,
  name: 'John',
  married: false 
}]

目前我用forkJoin并行请求两个接口，但在map操作符里需要遍历数据做匹配查找，想知道有没有更合适的RxJS运算符或方法来优化实现？当前代码如下：

const joint = forkJoin([mariage, subjects]);
return joint.pipe(
  map(responses => {
    responses[0].data.forEach((mItem) => {
      const found = responses[1].data.find((subj) => {
        return subj.id === mItem.hId;
      });
      mItem.married = found ? true : false;
    });
    console.log(responses[0].data);
    return responses[0].data;
  })
);

首先要指出：你当前的代码逻辑存在偏差——你是在婚姻数据中添加married字段，但需求是要富化人员数据。下面从效率和逻辑正确性两个角度优化：

1. 核心优化：降低查找复杂度 #

你当前用Array.find()做遍历匹配，时间复杂度是O(n²)，可以先把婚姻数据中的hId提取到Set中，这样判断人员是否已婚的操作复杂度降到O(1)。

2. 调整RxJS处理逻辑 #

forkJoin本身就是并行请求独立接口的最优选择，不需要更换其他操作符，重点优化map内的数据处理逻辑，同时修正目标数据集方向：

const joint = forkJoin([mariage, subjects]);
return joint.pipe(
  map(([marriageRes, personRes]) => {
    // 提取所有有婚姻记录的人员id集合
    const marriedIds = new Set(marriageRes.data.map(item => item.hId));
    // 遍历人员数据，添加married字段
    return personRes.data.map(person => ({
      ...person,
      married: marriedIds.has(person.id)
    }));
  })
);

额外说明 #

• 如果接口请求存在依赖关系（比如必须先获取婚姻数据才能请求人员数据），可以改用switchMap串联请求，但在这个场景下两个接口完全独立，forkJoin的并行请求效率更高。
• 用Set而非Map是因为我们只需要判断id是否存在，不需要存储额外关联数据，Set的has方法性能更优。

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