如何基于发射对象的values$创建提取a属性值的RxJS Observable？

嘿，你完全没必要用Subject绕圈子！RxJS里的map操作符就是专门干这种「转换每个发射值」的活儿的，正好匹配你的需求。

具体实现代码 #

你只需要在values$的管道里加上map操作符，直接提取每个对象的a属性就行：

import { map } from 'rxjs/operators';

// 你的原Observable
const value = { a: { foo: 'bar' }}; 
const values$ = Observable.from([value, value, value]);

// 新的Observable，直接发射a属性的值
const aValues$ = values$.pipe(
  map(item => item.a)
);

订阅使用 #

之后订阅这个新的aValues$时，每次拿到的就是你想要的a属性值，完全不需要额外逻辑：

aValues$.subscribe(a => {
  console.log(a); // 每次都会输出 { foo: 'bar' }
});

为什么这比用Subject好？ #

• 更简洁：直接通过管道式处理完成转换，不需要额外创建Subject来转发数据
• 更符合RxJS的设计理念：声明式地描述数据流的转换，代码可读性和维护性更高
• 避免冗余：不用手动管理Subject的next逻辑，减少出错的可能

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