error-handling - 向订阅RXJS发送错误

Question

我创建了一个应该捕获错误的函数:

private pipeError(): any {
 return catchError((error: HttpErrorResponse, caught: Observable<any>): 
                    HttpErrorResponse | any => {
 if (error.status === 400 || error.status === 402) {
    return Observable.throw(error);  
 } else if (error.status === 401) {
    this.router.navigate(['/login']);
    return Observable.throw(error);
   }
 });
}

然后，我创建了一个函数，该函数应该向api发送查询:

private post(path: string, data: Object, headers: HttpHeaders = this.getHeaders()): Observable<Object> {
    return this.http.post(`${this.apiUrl}${path}`, data, { headers }).pipe(
      this.pipeError(),
      map((response: Object): Object | any => {
        if (response instanceof Object) {
          return response;
        } else {
          return empty();
        }
      })
    );
  }

为了调用上面的函数，我创建了一个新函数，在其中传递了适当的参数:

userRegister(data: UserRegisterInterface): Observable<Object> {
    return this.post('accounts/register/', data);
  }

其他组件:
现在在另一个组件中，您订阅了此功能

this.createAccountSubscription = this.api.userRegister(datadata).subscribe((data) => {
      console.log(data);
    }, error => {
      console.log(error);
    });

我希望我的pipeError函数返回此错误订阅，但这不起作用，它可以:

enter image description here

Answer 1

您并不总是处理错误。我认为您可以这样重写pipeError():

import { throwError } from 'rxjs';

private pipeError(): any {
    return catchError((error: HttpErrorResponse, caught: Observable<any>):
        HttpErrorResponse | any => {
        if (error.status === 401) {
            this.router.navigate(['/login']);
        }

        return throwError(error);
    });
}