angular - 用尽 RxJs retryWhen 运算符尝试后如何抛出异常？

Question

我想在订阅中捕获异常，但结果不符合预期。

this.userService.isUsernameValid (username)
      .pipe (
          catchError (err =>
          {
            return throwError (err);
          }),
          retryWhen (errors =>
              errors.pipe (
                  delay (2500),
                  take (4),
                  concatMap (() => throwError ('Network error'))
              )
          )
       )
      .subscribe (
          data =>
          {
            //
          },
          error =>
          {
            console.log (error)
          });

我希望只有在所有尝试都失败时才抛出异常。

上面的代码只发出第一个请求，如果出错则抛出异常(不重做请求)。

如果我删除 concatMap，将进行 4 次尝试，但如果没有成功，我将无法在订阅中捕获错误。

提前致谢。

Answer 1

您可以在特定条件下自己重新抛出错误。例如 concatMap 将 index 参数传递给它的投影函数，您可以使用它来代替 take():

throwError("It's broken")
  .pipe(
    retryWhen(errors => errors.pipe(
      concatMap((e, index) => index === 4 ? throwError(e) : of(null)),
    )),
  )
  .subscribe({
    next: x => console.log(x),
    error: e => console.log('obs', e),
  });

现场演示:https://stackblitz.com/edit/rxjs-kyr8zp