首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >合并连续观察值结果的最佳方法是什么?

合并连续观察值结果的最佳方法是什么?
EN

Stack Overflow用户
提问于 2019-01-02 22:09:56
回答 3查看 739关注 0票数 2

假设我有一个Observable,它产生了一个包含3个数组的对象,如下所示:

代码语言:javascript
运行
复制
    results = {
        type1: [...],
        type2: [...],
        type3: [...],
    };

是否有一个rxjs运算符,允许我将多个观察值及其结果组合在一起,以获得如下所示的最终结果:

代码语言:javascript
运行
复制
    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运算符,但根据他们的文档,我不确定它们是否可以做类似“深度合并??”

感谢你的帮助

EN

回答 3

Stack Overflow用户

发布于 2019-01-02 22:45:59

您要查找的是扫描操作符:

https://www.learnrxjs.io/operators/transformation/scan.html

它类似于reduce操作符,但reduce操作符仅在流的末尾发出。扫描操作符每次都会发出中间值。

票数 3
EN

Stack Overflow用户

发布于 2019-01-02 22:18:23

这与可观察性无关,这是普通的旧Javascript。

您唯一需要知道的运算符是combineLatest

代码语言:javascript
运行
复制
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。

票数 1
EN

Stack Overflow用户

发布于 2019-01-02 22:32:28

您可以使用reduce运算符从多个发出的值中聚合单个结果。合并单个数组由您决定,因为这与rxjs无关

简单的例子:https://stackblitz.com/edit/angular-cffyyh

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/54007829

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档