假设我有一个Observable,它产生了一个包含3个数组的对象,如下所示:
results = {
type1: [...],
type2: [...],
type3: [...],
};
是否有一个rxjs运算符,允许我将多个观察值及其结果组合在一起,以获得如下所示的最终结果:
results1 = {
type1: [1, 2],
type2: ['ab', 'cd'],
type3: ['foo', 'bar'],
};
results2 = {
type1: [3, 4, 5],
type2: ['ef', 'gh', 'ij'],
type3: ['ban', 'jo', 'vi'],
};
final_results = {
type1: [1, 2, 3, 4, 5],
type2: ['ab', 'cd', 'ef', 'gh', 'ij'],
type3: ['foo', 'bar', 'ban', 'jo', 'vi'],
};
?
为了记录,我使用了Angular 2+和typescript,并且我想继续使用可观察到的流和rxjs运算符,但根据他们的文档,我不确定它们是否可以做类似“深度合并??”
感谢你的帮助
发布于 2019-01-02 22:45:59
您要查找的是扫描操作符:
https://www.learnrxjs.io/operators/transformation/scan.html
它类似于reduce操作符,但reduce操作符仅在流的末尾发出。扫描操作符每次都会发出中间值。
发布于 2019-01-02 22:18:23
这与可观察性无关,这是普通的旧Javascript。
您唯一需要知道的运算符是combineLatest
:
combineLatest(results1$, results2$).pipe(
map((results1, results2) => {
const ret = {};
Object.keys(results1).foreEach(key => ret[key] = results1[key].concat(results2[key]));
return ret;
})
).subscribe(res => console.log(res)); // should display your expected result
请不要误会: RxJS操作符操作流(可观察对象本身),而不是其中的数据。
如果你想处理内部数据,这就变成了Javascript。
发布于 2019-01-02 22:32:28
您可以使用reduce运算符从多个发出的值中聚合单个结果。合并单个数组由您决定,因为这与rxjs无关
https://stackoverflow.com/questions/54007829
复制相似问题