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

Question

我有一个奇怪的问题。

我有一个服务，它从后端获取数据，功能如下：

  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));
  }

我的问题是，当我订阅这个可观察对象（在组件初始化时只订阅一次）并且 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()）只被记录了一次。

会是什么？

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

Answer 1

有点摸不着头脑，但 shareReplay 通常会保持连接，即使它们已取消订阅。

尝试使用

    return this.http.post<User>(callUrl, token, environment.httpOptions)
      .pipe(publishReplay(1), refCount(), retry(0));

Answer 2

您不止一次订阅了该 http 调用。它不共享它的发射，因为每次调用它时都会调用 validateChangEmailTokenAndChangeEmail() returns 不同的可观察对象。

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

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

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

Answer 3

我发现了我遇到的问题。

基本上我已经实现了一个名为 HttpErrorInterceptor 的 class，它有一个内部带有 retry(1) 的管道。这就是导致错误的每个请求都被重复的原因。

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

Duplicate request is always performed when the request throws an error

angular

http

angular-httpclient