How to throw the original error when using rxjs retryWhen with zero retries

Question

I am creating an Angular Http Retry Interceptor. When I have retries of 1, my code looks like this:

  return next.handle(req).pipe(
    retryWhen((error) => {
      return error.pipe(
        delay(1000),
        take(1),
        concatMap((err) => {
          return _throw({ ...err, message: `Sorry, there was an error (after 1 retry)` });
        })
      );
    })
  );

This seems to work. I can throw with the original error.

Now, when the retries is zero, this doesn't work. I think that's because we are doing take(0). However, the concat operator will work:

  return next.handle(req).pipe(
    retryWhen((error) => {
      return error.pipe(
        delay(1000),
        take(0),
        concat(_throw({ message: `Sorry, there was an error (after 0 retries)` }))
      );
    })
  );

But the problem is that I can't get the original error. What other operators can I use in my zero retry scenario to get/throw the original error?

See this answer: https://stackoverflow.com/a/44911567/2521865 — paulpdaniels, Aug 18 '18 at 04:15

score 4 · Answer 1 · answered Aug 18 '18 at 07:25

Thanks to paulpdaniels's link. Here is what works for me:

    return next.handle(req).pipe(
      retryWhen((error) => {
        return error.pipe(
          concatMap((e, i) => {
            if (i >= retries) {
              return throwError({ ...e, retries });
            }
            return of(e).pipe(tap(() => log.error(e)), delay(retryInterval as number));
          })
        );
      })
    );

We don't use take anymore and the delay is within concatMap

How to throw the original error when using rxjs retryWhen with zero retries

1 Answers1