angular - 请求抛出错误时总是执行重复请求

问题描述

我有一个奇怪的问题。

我有一个服务，它从后端获取数据和一个像这样的函数：

  validateChangEmailTokenAndChangeEmail(token: string): Observable<User>
  {
    const callUrl = environment.apiUrl + `users/validate-change-email-token-and-change-email`;
    return this.http.post<User>(callUrl, token, environment.httpOptions)
      .pipe(shareReplay(), retry(0));
  }

我的问题是，当我订阅这个 observable（组件初始化时只订阅一次）并且 BE 抛出错误时，请求将再执行一次。我尝试添加shareReplay(),retry(0)和take(1). 但仍然没有成功。

这是我的订阅：

this.userService.validateChangEmailTokenAndChangeEmail(this.token)
      .subscribe(user => {
       // my logic

      }, error =>
      {
        // handling of error
        this.handleError(error);
      });

该函数this.handleError()只会被调用一次。这意味着重复的请求并没有真正被接受和处理。

检查下面的屏幕截图。请求错误被记录 2 次，WTF（来自handleError()）仅记录一次。

会是什么呢？

我还注意到，订阅将始终接受第二个请求。

标签： angularhttpangular-httpclient

您不止一次订阅该 http 调用。它没有共享它的发射，因为validateChangEmailTokenAndChangeEmail()每次调用它都会返回一个不同的 observable。

为了实现您所追求的，您实际上需要将该方法的结果分配给一个局部变量，然后您可以在 n 上重新订阅该局部变量。

validate$ = this.myService.validateChangEmailTokenAndChangeEmail(this.token);

ngOnInit() {
    this.validate$.subscribe(console.log);
    this.validate$.subscribe(console.log);
}

angular - 请求抛出错误时总是执行重复请求

问题描述

解决方案

推荐阅读