Rxjs Retry with Delay function

by

delay() is used to introduce a delay between events emitted by the observable. But the observable never emits any event. It just errors immediately.

What you’re looking for is retryWhen(), which allows deciding after how long to retry:

RxJS 5:

  .retryWhen(errors => errors.delay(1000).take(10))

RxJS 6:

import { retryWhen, delay, take } from 'rxjs/operators'
someFunction().pipe(
  // ...
  retryWhen(errors => errors.pipe(delay(1000), take(10)))
)

This will complete the whole observable after 10 attempts. If you want to error the whole observable after 10 attempts, the observable returned by the retryWhen callback must throw:

RxJS 5:

  .retryWhen(errors => errors.delay(1000).take(10).concat(Observable.throw()))

RxJS 6:

import { retryWhen, delay, take, concatMap, throwError } from 'rxjs/operators'
someFunction().pipe(
  // ...
  retryWhen(errors => errors.pipe(delay(1000), take(10), concatMap(throwError)))
)

More Related Contents:

  1. What is the difference between Subject and BehaviorSubject?
  2. How to cancel/unsubscribe all pending HTTP requests in Angular 4+
  3. How to make a sequence of http requests in Angular 6 using RxJS
  4. Angular subscribe elegant
  5. Best way to import Observable from rxjs
  6. TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable
  7. Behaviour subject initial value null?
  8. rxjs/Subject.d.ts error : Class ‘Subject’ incorrectly extends base class ‘Observable’
  9. Subscribing to a nested Observable
  10. What is pipe for in RxJS?
  11. How to throw error from RxJS map operator (angular)
  12. How to return observable from subscribe
  13. Property ‘toPromise’ does not exist on type ‘Observable’
  14. How to return value inside subscribe Angular 4
  15. Do I need to `complete()` takeUntil Subject inside ngOnDestroy?
  16. How to pass results between chained observables
  17. Convert Promise to Observable
  18. document.getElementById replacement in angular4 / typescript?
  19. localStorage is not defined (Angular Universal)
  20. Page is part of the declarations of 2 modules: Error in ionic build prod
  21. Uncaught Error: Unexpected directive ‘MyComboBox’ imported by the module ‘AppModule’. Please add a @NgModule annotation
  22. Angular 2 Read More Directive
  23. When to use Interface and Model in TypeScript / Angular
  24. How to display the app version in Angular?
  25. How to pass data to dialog of angular material 2
  26. access SASS values ($colors from variables.scss) in Typescript (Angular2 ionic2)
  27. Angular 4/5 HttpClient: Argument of type string is not assignable to ‘body’
  28. How to get rid of the warning .ts file is part of the TypeScript compilation but it’s unused
  29. Angular 2 : No NgModule metadata found
  30. How to make nested Observable calls in Angular2

Leave a Comment