0

我有一个像这样响应的 api，我正在使用 rxjs observables

[{
  "error": "error_1",
  "types": [
     {
       "type": "new_type"
     },
     {
       "type": "old_type"
     }
  ],
  "date": "2019-08-29"
}]

我需要将其转换为新的 json 格式，以便获得我想要的响应格式。

我已经尝试过 pipe(map()) 但我收到 Type ' 的错误Observable<void> ”不可分配给类型“ Observable<Error[]>”

我的模特

export interface Data {
    error: string,
    types: Types[],
    date: string
}

interface Types {
    type: string
}

我的服务.ts

getError(): Observable<Data[]> {
    return this.http.get<Data[]>(url);
  }

这是我到目前为止所尝试的，我删除了产生错误 My Component.ts 的代码

getUserErrors(user): Observable<Data[]> {
    return this.getData.getError()
      .pipe(map((x) => x.filter(one => one.error !== null)))
}

这是我需要的可观察输出

[{
  "new_error": "error_1",
  "type_1": "new_type",
  "date": "2019-08-29"
}]

感谢那些愿意提供帮助的人

4

1 回答 1

0

据我了解，您需要过滤掉带有空错误的响应，然后将剩余元素映射到新格式，并将其作为另一种Observable. 您可以使用flatMap为了将多个Observables 链接在一起：

getUserErrors(user): Observable<Data[]> {
    return this.getError()
        .flatMap(result => {
            result = result.filter(elem => elem.error !== null)
                .map(elem => ({
                    new_error: elem.error,
                    type_1: elem.types[0].type, // since you want the first out of the two
                    date: elem.date
                }));
            return Observable.of(result);
        })
}

稍后当你调用它时：

this.getUserErrors(user).subscribe(
    result => { console.log(result); }
    error => { console.log(error); /* Do some proper error handling */ }
)
于 2019-08-29T06:05:14.940 回答