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

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

在处理 Observable 数据流时，常需从原始对象数组中提取特定字段（如 dept），同时确保该字段存在且不重复。直接在 map 中嵌套过滤逻辑不仅可读性差，还容易因遗漏 return 或作用域错误导致语法/运行时问题（如原代码中 allObjects 未定义、filter 回调未返回布尔值、Set 误用等）。

正确的做法是分层处理：先用 filter 筛出含有效 dept 的对象，再用 map 提取字段值，最后用 distinct() 自动去重。整个流程符合函数式编程的单一职责原则，也与 RxJS 的响应式设计哲学一致。

以下是推荐实现：

Wjs Uploading Video

将一个或多个视频上传至YouTube。当用户想“上传到YouTube”“发YouTube”“批量上传”“upload to YouTube”“post videos to YouTube”或发布到YouTube时使用此技能。

下载

myDepts$ = this.myDummyService.getMyObjects().pipe(
  filter((obj: any) => obj.dept !== undefined && obj.dept !== null), // 安全过滤：排除 undefined 和 null
  map((obj: any) => obj.dept),
  distinct() // 内置基于严格相等（===）的去重
);

⚠️ 注意事项：

• distinct() 默认使用 === 比较，适用于数字、字符串等基础类型；若 dept 是对象或需自定义比较逻辑（如忽略大小写），应改用 distinct((dept) => dept?.toString().toLowerCase()) 或 distinctUntilChanged() 配合 sort 预处理；
• filter 中建议同时检查 null（因 null !== undefined 为 true，但通常也不应保留）；
• 若数据源是 Observable（即一次性发出整个数组），需先用 mergeAll() 或 concatAll() 展平，或改用 flatMap + from 转为逐项流——但本例中 getMyObjects() 更可能返回单个数组，因此上述写法已适配常见服务接口模式；
• 类型安全提示：应避免 any，建议定义接口如 interface MyObject { code?: number; dept?: number; height?: number; }，提升可维护性。

最终，订阅 myDepts$ 将按顺序收到去重后的 dept 值（如 [2]），无冗余、无异常，简洁可靠。