本文介绍如何通过 RxJS 的 filter、map 和 distinct 操作符，从对象流中安全提取非空且唯一的 dept 字段值，避免 undefined 和重复项。

本文介绍如何通过 rxjs 的 `filter`、`map` 和 `distinct` 操作符，从对象流中安全提取非空且唯一的 `dept` 字段值，避免 undefined 和重复项。

在处理 Observable 数据流时，常需从嵌套对象中提取特定字段（如 dept），同时确保该字段存在、非 undefined，且最终结果无重复。原始实现试图在 map 内部使用 filter 和 Set 手动去重，但存在多重问题：map 未返回值、变量名混淆（allObjects 未定义）、distinct 误用为高阶函数形式，且 distinct() 需配合 pipe 正确调用。

正确的做法是分步链式处理，利用 RxJS 内置操作符各司其职：

chartjs-reporter

此技能用于在用户需要将结构化数据（查询结果、CSV 摘要、JSON 记录或 Python 字典/列表）转换为独立的 HTML 页面时使用。

下载

1. filter：先筛除 dept 缺失的对象；
2. map：再投影出纯 dept 值；
3. distinct()：对数值流自动去重（内部基于 === 比较）。

myDepts$ = this.myDummyService.getMyObjects().pipe(
  filter((obj: any) => obj.dept !== undefined && obj.dept !== null), // 更健壮：同时排除 null
  map((obj: any) => obj.dept),
  distinct()
);

✅ 注意事项：

• distinct() 默认对整个流中的每个发出值进行全量比较去重，适用于基础类型（如 number、string）；若需自定义逻辑（如对象深比较），应使用 distinct((value) => value.id) 或 distinctUntilChanged()。
• 若源 Observable 发出的是数组（如你的示例中 getMyObjects() 返回 Observable<Array<T>>），则上述代码需调整为先 mergeMap 或 flatMap 展平：

  myDepts$ = this.myDummyService.getMyObjects().pipe(
    mergeMap(arr => arr), // 将数组流展平为单个对象流
    filter((obj: any) => obj.dept != null), // 简洁写法：涵盖 undefined 和 null
    map((obj: any) => obj.dept),
    distinct()
  );

• 类型安全建议：避免 any，定义接口如 interface MyObject { code?: number; dept?: number; height?: number; }，提升可维护性。

最终，订阅 myDepts$ 将按顺序收到所有唯一、非空的部门编号（如 [2]），完全满足“提取 dept、去 undefined、去重”三大需求。