Observable 的转换

Posted

技术标签:

【中文标题】Observable 的转换【英文标题】:Transformation of Observable 【发布时间】:2020-04-02 19:24:18 【问题描述】:

我有一个如下所示的数据结构:

 Observable<Array<LineChart>>

LineChart 的定义如下

export interface LineChart  
  name?: null | string;
  series?: null | Array<DateLineChartEntry>;

一个 DateLineChartEntry 是这样定义的:

export interface DateLineChartEntry  
  name?: string;
  value?: number;

其中name是字符串,包含日期。

对于我对这个 DataStructure 的后续操作,我需要将 DateLineChartEntry 转换为 sth。像这样:

export interface DateLineChartEntryConverted  
  name?: Date;
  value?: number;

这意味着,我必须像这样映射所有 DateLineChartEntries

DateLineChartEntry  => 
name: new Date(name),
value: value

我目前的解决方案是这样的:

    this.data = getObservable( body: parameters ).pipe(
  map(lca => 
    var lcaConverted = [];

    for (var lc of lca) 
      var name = lc.name
      var lcN = 
        name: name,
        series: []
      ;

      for (var e of lc.series) 
        var n = new Date(e.name);
        lcN.series.push(
          name: n,
          value: e.value
        );
      

      lcaConverted.push(lcN);
    

    return lcaConverted;
  )
);

这很丑陋,我正在寻找一个“更好”的解决方案。

有没有一种简单的方法可以通过使用初始 Observable(并接收 Observable 作为输出)来做到这一点?

提前感谢您的帮助。

【问题讨论】:

到目前为止你尝试了什么? 这基本上是我的问题 - 从来没有真正基于“接收某些东西并将其放在某处”的基础上使用可观察(或转换) - 所以我已经在“从哪里开始”失败了。首先方法是使用“管道”,然后在所有数据上使用一些 foreachs 重新创建对象。但似乎根本没有成功。最大的问题:我不知道如何调试我的中间结果。 对不起,你的目标我不清楚..你能用你到目前为止尝试的代码更新吗? 添加了我当前的(工作)解决方案,这不是很“好”:-) 【参考方案1】:

您只是在寻找更清洁的东西吗?如果是这样,请查看一些较新的数组功能,而不是编写 for

this.data = getObservable(
        body: parameters
    ).pipe(
        map(lca => lca.map(entry => (
                    name: entry.name,
                    series: entry.series.map(x => (
                        name: new Date(x.name),
                        value: x.value
                    ))
                ))
            )
        );

具体.map:https://developer.mozilla.org/en-US/docs/Web/javascript/Reference/Global_Objects/Array/map

【讨论】:

是的,这正是我想要的(特别是数组的地图)-非常感谢您的帮助!

以上是关于Observable 的转换的主要内容,如果未能解决你的问题,请参考以下文章

在 RxSwift 中将 [Observable<T>] 转换为 Observable<[T]>

如何将 Observable 转换为 ReplaySubject?

Observable 的转换

RxJava- 操作符之转换Observable

你可以转换 switchMap observable 的结果来获取它的值而不是 observable 本身吗?

为啥重复 Enumerable 到 Observable 转换块