rxjs catchError 从角度服务管道传输时不起作用

Question

使用 redux 和 Angular，我有以下效果：

@Effect()
public authenticate: Observable<Action> = this.actions
.ofType(AUTHENTICATE)
.pipe(
map((action: AuthenticateAction) => action.payload),
switchMap(payload => {
return this.userService.authenticateUser(payload.email, payload.password).pipe(
map(auth => new AuthenticationSuccessAction({ auth: auth })),
catchError(error => of(new HttpErrorAction({ error: error })))
);
})
);

服务内容：

public authenticateUser(email: string, password: string): Observable<IAuthentication> {
const formData: FormData = new FormData();
formData.append('email', email);
formData.append('password', password);
return this.httpClient.post('/api/auths/useraccounts', formData) as Observable<IAuthentication>;
}

当开机自检失败时，永远不会调度 HttpErrorAction。

Answer 1

原来我忘记了我有一个 HttpInterceptor，我捕获了这样的 http 错误：

return next.handle(authReq).pipe(catchError(
(error) => {
return of(error);
}

如果我想将错误冒泡到这样的效果，我会做这样的事情：

return Observable.throw(error);

使用较新版本的 rxjs 进行更新：

return throwError(error);