Handling refresh tokens using rxjs

by

From a quick look at your code I would say that your problem seems to be that you are not flattening the Observable that is returned from the refresh service.

The catch operator expects that you will return an Observable that it will concatenate onto the end of the failed Observable so that the down stream Observer doesn’t know the difference.

In the non-401 case you are doing this correctly by returning an Observable that rethrows the initial error. However in the refresh case you are returning an Observable the produces more Observables instead of single values.

I would suggest you change the refresh logic to be:

    return me.authService
             .refreshAuthenticationObservable()
             //Use flatMap instead of map
             .flatMap((authenticationResult:AuthenticationResult) => {
                   if (authenticationResult.IsAuthenticated == true) {
                     // retry with new token
                     me.authService.setAuthorizationHeader(request.headers);
                     return this.http.request(url, request);
                   }
                   return Observable.throw(initialError);
    });

flatMap will convert the intermediate Observables into a single stream.

More Related Contents:

  1. What is the difference between Promises and Observables?
  2. What is the difference between Subject and BehaviorSubject?
  3. Angular HTTP GET with TypeScript error http.get(…).map is not a function in [null]
  4. Convert Promise to Observable
  5. Observable type error: cannot read property of undefined
  6. take(1) vs first()
  7. RxJS: takeUntil() Angular component’s ngOnDestroy()
  8. Angular Subscribe within Subscribe
  9. How to create an RXjs RetryWhen with delay and limit on tries
  10. Best way to “flatten” an array inside an RxJS Observable
  11. How to make an http call every 2 minutes with RXJS?
  12. Angular 7 – nesting Observables
  13. Angular subscribe elegant
  14. Making sure observables in for loop are all finished before executing other code
  15. Best way to import Observable from rxjs
  16. TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable
  17. fromPromise does not exist on type Observable
  18. rxjs/Subject.d.ts error : Class ‘Subject’ incorrectly extends base class ‘Observable’
  19. Rxjs Retry with Delay function
  20. How to make nested Observable calls in Angular2
  21. tap() isn’t triggered in RXJS Pipe
  22. Subscribing to a nested Observable
  23. What is pipe for in RxJS?
  24. How to throw error from RxJS map operator (angular)
  25. How to return observable from subscribe
  26. Angular 5 to 6 Upgrade: Property ‘map’ does not exist on type Observable
  27. Do I need to `complete()` takeUntil Subject inside ngOnDestroy?
  28. Angular2 watch for 302 redirect when fetching resource
  29. FormControl.detectchanges – why use distinctUntilChanged?
  30. How to send 1000 XHTTP Requests with maximum number of parallel requests

Leave a Comment