0

在服务器做出错误响应后，我的应用程序不会发送任何进一步的请求。

我正在发送一个请求：

getMachineRules(rules: Array<string>): Observable<RulesResults> {
    return this.http.post<RulesResults>('/rules', { nodes: rules })
      .pipe(
        catchError(this.handleError)
      );
  }

我的错误处理程序：

  handleError(error) {
    if (error.error instanceof ErrorEvent) {
      console.error('An error occurred:', error.error.message);
    } else {
      console.error(
        `Backend returned code ${error.status}, ` +
        `body was: ${JSON.stringify(error.error)}`);
    }
    return throwError('Something bad happened; please try again later.');
  }

我的管道如下所示：

  ngAfterViewInit() {
    this.rulesChanged
      .pipe(
        startWith({}),
        switchMap(() => {
          this.isLoadingResults = true;
          return this.settings.getMachineRules(this.currentRules);
        }),
        map(data => {
          this.isLoadingResults = false;
          this.resultsLength = data.inputs?.length || 0;
          return data;
        }),
        catchError(e => {
          console.log("Error caught");
          this.isLoadingResults = false;
          this.resultsLength = 0;
          return observableOf({ inputs: [] } as RulesResults);
        })
      ).subscribe(
        data => { return this.updateRules(data); },
      );
  }

我可以在控制台中看到“错误捕获”消息，updateRules()即使在错误情况下，该方法似乎也能正常工作。

但是，在 404-Error-Response 之后，ngAfterViewInit()不再调用该方法。UI 钢对交互做出反应。

4

1 回答 1

2

一旦 Obsevable 失败，您将无法再次激活它，catchError用于通过返回新的 observable或抛出错误来处理错误。在主流失败的情况下observableOf({ inputs: [] } as RulesResults)用作替代，这意味着您的主要 Observable 将永远不会再次发出。

考虑retry在管道的末尾使用，或者选择 catchError返回源 Observable 本身，如下所示：

catchError((error, source) => {
 ....
  return source;
})

或者将catchError运算符放在 aswitchMap中，这样只有内部流会失败，而外部（主）流将保持活动状态，如下所示：

ngAfterViewInit() {
  this.rulesChanged
    .pipe(
      startWith({}),
      switchMap(() => {
        this.isLoadingResults = true;
        return this.settings.getMachineRules(this.currentRules).pipe(
          map(data => {
            this.isLoadingResults = false;
            this.resultsLength = data.inputs?.length || 0;
            return data;
          }),
          catchError(e => {
            console.log("Error caught");
            this.isLoadingResults = false;
            this.resultsLength = 0;
            return observableOf({ inputs: [] } as RulesResults);
          })
        )
      })
    ).subscribe(
      data => { return this.updateRules(data); },
    );
于 2020-12-14T17:23:17.787 回答