Angular Interceptor для добавления токена и автоматического обновления

Я впервые работаю с угловыми перехватчиками, и у меня почти есть то, что я хочу, но есть кое-что, что я не могу понять, даже после того, как некоторое время погуглил. Я храню токен обновления локально, а срок действия токена доступа истекает каждые 15 минут; Я хочу иметь возможность использовать токен обновления для автоматического обновления своего токена аутентификации по истечении срока его действия.

Моя первая попытка была такой:

intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
if (req.url.toLowerCase().includes('/auth')) {
  // It's an auth request, don't get a token
  return next.handle(req);
}

// Not an auth endpoint, should have a token
this.authService.GetCurrentToken().subscribe(token => {
  // Make sure we got something
  if (token == null || token === '') {
    return next.handle(req);
  }

  // Have a token, add it
  const request = req.clone({
    setHeaders: {
      Authorization: `Bearer ${token}`
    }
  });

  return next.handle(request);
});
}

Похоже, это не сработало, и я не мог понять, почему (я новичок в Angular и довольно новичок в JS, так что извините, если это очевидно для других). Подозревая, я задавался вопросом, было ли это наблюдаемым, что все испортило, и ему не нравится ждать, пока наблюдаемое вернется, поэтому я попробовал это:

  intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
if (req.url.toLowerCase().includes('/auth')) {
  // It's an auth request, don't get a token
  return next.handle(req);
}

const token = this.authService.GetAccessTokenWithoutRefresh();
const request = req.clone({
  setHeaders: {
    Authorization: `Bearer ${token}`
  }
});
return next.handle(request);   
}

И теперь это, кажется, работает! Это говорит о том, что я, возможно, был прав в своей догадке (или что это что-то еще внутри другого кода, которого я не вижу). В любом случае, работает хорошо, но это оставляет меня с вопросом, как обновить. Первоначальная причина, по которой я использовал наблюдаемую из службы аутентификации, заключалась в том, что ее нужно было обновить. В основном служба аутентификации будет смотреть на свой текущий токен и смотреть, истек ли срок его действия или нет. В противном случае он просто вернет of(token), но если срок его действия истек, он будет обращаться к серверу через http-сообщение, которое можно наблюдать, поэтому строка будет приходить всякий раз, когда сервер отвечает.

Поэтому я думаю, что мой вопрос двоякий:

1. Может ли кто-нибудь подтвердить или опровергнуть, что я был прав насчет наблюдаемой неисправности перехватчика? Вроде проблема в нем, но хотелось бы удостовериться.
2. Как мне справиться с обновлением токена для них в фоновом режиме без необходимости повторного входа в систему каждые 15 минут?

РЕДАКТИРОВАТЬ

Вот логика в методе токена авторизации:

GetCurrentToken(): Observable<string> {
if (this.AccessToken == null) {
  return null;
}
if (this.Expiry > new Date()) {
  return of(this.AccessToken);
}

// Need to refresh
return this.RefreshToken().pipe(
  map<LoginResult, string>(result => {
    return result.Success ? result.AccessToken : null;
  })
);
}

и метод обновления:

private RefreshToken(): Observable<LoginResult> {
const refreshToken = localStorage.getItem('rt');
if (refreshToken == null || refreshToken === '') {
  const result = new LoginResult();
  // Set other stuff on result object
  return of(result);
}

const refresh = new RefreshTokenDto();
refresh.MachineId = 'WebPortal';
refresh.TokenId = refreshToken;
return this.http.post(ApiData.baseUrl + '/auth/refresh', refresh)
  .pipe(
    tap<AuthResultDto>(authObject => {
      this.SetLocalData(authObject);
    }),
    map<AuthResultDto, LoginResult>(authObject => {
      const result = new LoginResult();
      // Set other stuff on the result object
      return result;
    }),
    catchError(this.handleError<LoginResult>('Refresh'))
  );
}

РЕДАКТИРОВАТЬ

Итак, с помощью ответа ниже, а также вопроса это вот что я придумал:

intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
if (req.url.toLowerCase().includes('/auth')) {
  // It's an auth request, don't get a token
  return next.handle(req.clone());
}

return this.authService.GetCurrentToken().pipe(
  mergeMap((token: string) => {
    if (token === null || token === '') {
      throw new Error('Refresh failed to get token');
    } else {
      return next.handle(req.clone({setHeaders: {Authorization: `Bearer ${token}`}}));
    }
  }),
  catchError((err: HttpErrorResponse) => {
    if (err.status === 401) {
      this.router.navigateByUrl('/login');
    }
    return throwError(err);
  })
);
}

В общем, моя первая попытка была не так уж и далека, «секрет» заключался в том, чтобы использовать конвейер и карту слияния вместо того, чтобы пытаться подписаться.