forkjoin url中的Angular 2/4错误处理

Question

我是 usimg angular 2，我正在使用 forkjoin 来处理我必须并行执行多个 rest 调用的场景之一。以下是我的函数

 private getBatchObservableData(data: Array<Widget>): Observable<any> {
    let observableBatch = [];
    data.forEach(widget => {
      observableBatch.push(this._http.get(widget.apiPath).delay(500).map((data) => data.json()).share())
    });
    return Observable.forkJoin(observableBatch);
  }

这工作得非常好。但是当任何一个其余调用失败时，wholeforkjoin 都会失败。所以有没有办法发出这些休息调用的值并记录失败的情况。 ??请帮忙。

Answer 1

如果您使用catch 来防止错误冒泡到forkJoin 调用，您可以将它们作为值重新发出，并可以检查forkJoin 的可选项目函数中的值：

private getBatchObservableData(data: Array<Widget>): Observable<any> {
  let observableBatch = [];
  data.forEach(widget => observableBatch.push(this._http
    .get(widget.apiPath)
    .delay(500)
    .map(data => data.json())
    .catch(error => Observable.of(error))
  ));
  return Observable.forkJoin(observableBatch,
    (...results) => ({
      failed: results.map(r => r instanceof Error ? r : null),
      succeeded: results.map(r => r instanceof Error ? null : r)
    })
  );
}

上面的示例将发出一个包含两个数组的对象，每个数组都包含与data 数组相同数量的元素：

• 如果相应的请求失败，failed 中的元素将包含 Error，否则将包含 null。
• 如果相应的请求成功，succeeded 中的元素将包含数据，否则 null。

如果你需要做一些不同的事情，重新安排事情应该很容易。