Angular中.pipe()后调用.subscribe()时重定向代码未执行问题

1. 修复throwError写法适配RxJS版本 #

RxJS 7.x及以上版本中，throwError不再支持直接传入错误值，要求传入返回错误的工厂函数。如果你的项目依赖RxJS 7+，当前_throwError方法的写法会导致流异常终止，无法触发组件侧的next回调。
修复代码：

private _throwError = error => {
  const errorMessage = error.error.error.message;
  // 适配RxJS 7+的写法
  return throwError(() => errorMessage);
};

2. 检查_createAndEmitUserSubject内的同步错误 #

你当前的User实例化代码中，第三个参数重复传入了response.idToken，通常用户模型的第三个参数应为response.refreshToken。如果你的User类构造函数对该参数有校验逻辑，或后续操作依赖refreshToken的有效值，此处会抛出同步错误。tap操作符内的同步错误会直接进入错误流、触发catchError，导致组件侧next回调不执行。
修复代码示例（可根据你实际User类的参数定义调整）：

private _createAndEmitUserSubject = (response: AuthResponseData) => {
  const expirationDate = new Date(new Date().getTime() + +response.expiresIn * 1000);
  const user = new User(
    response.localId, // 通常第一个参数为用户ID，可根据实际接口返回调整
    response.email,
    response.refreshToken, // 修正为refreshToken字段
    expirationDate
  );

  localStorage.setItem("user", JSON.stringify(user));
  this.user$.next(user);
};

3. 可选：添加调试日志快速定位问题 #

如果上述修改后仍未解决，可在pipe中添加日志确认执行链路：

private _signInOrSignUp = (endpoint: string, data: SignIn | SignUp): Observable<AuthResponseData> => {
  return this.http.post<AuthResponseData>(endpoint, {
    ...data,
    returnSecureToken: true
  }).pipe(
    tap(res => console.log('接口请求成功', res)),
    catchError(error => {
      console.log('接口报错', error);
      return this._throwError(error);
    }),
    tap(response => {
      console.log('开始处理用户数据');
      this._createAndEmitUserSubject(response);
    }),
  );
}

通过控制台输出即可判断是接口请求、错误处理还是用户数据处理环节出了问题。

内容的提问来源于stack exchange，提问作者user4383363