如何改变存储在RxJS Observable中的数据？

Question

我在Angular 2应用程序中编写了一个方法，在进行一个返回JSON的服务器调用之后，创建并返回一个类的可观察对象。但是，JSON的格式很差，所以我需要一个快速修复方法来编辑返回的JSON，然后再将其发送到< code >。json()方法，由于json格式不良，该方法当前抛出一个错误。

具体来说，我需要在JSON中找到一个错误的逗号，它出现在数组的右括号之后，并删除它。

我的问题

Observable.map函数到底应该是什么样的？我如何找到并操作实际的JSON字符串，然后将其一起发送？我对所有这些都不熟悉，所以如果有详细信息，将不胜感激。

getList(): Observable<Thing[]> {
  let response = this.http.get('/api/get-things');
  let fixed = response.map(____WHAT GOES HERE?_____);
  return fixed.map((r: Response) =>r.json as Thing[]);
}

Answer 1

假设您有一个修复方法：

const fix = (json: string) => {
  // ...
}

你可以这样做:

const things: Observable<Thing[]> = this.http.get('/api/get-things')
  .map(response => response.text())
  .map(fix)
  .map(fixedJson => JSON.parse(fixedJson) as Thing[])

然而，这是一个非常糟糕的主意。修复服务器端代码！