How to catch error and continue executing a sequence in RxJs?

by

I would suggest that you use flatMap (now mergeMap in rxjs version 5) instead, which will let you collapse errors if you don’t care about them. Effectively, you will create an inner Observable that can be swallowed if an error occurs. The advantage of this approach is that you can chain together operators and if an error occurs anywhere in the pipeline it will automatically get forwarded to the catch block.

const {from, iif, throwError, of, EMPTY} = rxjs;
const {map, flatMap, catchError} = rxjs.operators;

// A helper method to let us create arbitrary operators
const {pipe} = rxjs;

// Create an operator that will catch and squash errors
// This returns a function of the shape of Observable<T> => Observable<R>
const mapAndContinueOnError = pipe(
  //This will get skipped if upstream throws an error
  map(v => v * 2),
  catchError(err => {
    console.log("Caught Error, continuing")
    //Return an empty Observable which gets collapsed in the output
    return EMPTY;
  })
)

const observable = from([0, 1, 2, 3, 4, 5]).pipe(
  flatMap((value) => 
    iif(() => value != 3, 
      of(value), 
      throwError(new Error("Value cannot be 3"))
    ).pipe(mapAndContinueOnError)
  )
);

observable.subscribe(
  (value) => console.log("onNext " + value), (error) => console.log("Error: " + error.message), () => console.log("Completed!")
);
<script src="https://unpkg.com/[email protected]/dist/bundles/rxjs.umd.min.js"></script>

More Related Contents:

  1. Angular 7 go offline?
  2. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  3. How to get current value of RxJS Subject or Observable?
  4. BehaviorSubject vs Observable?
  5. Angular 4 Interceptor retry requests after token refresh
  6. Why do we need to use flatMap?
  7. How can I close a dropdown on click outside?
  8. What is “callback hell” and how and why does RX solve it?
  9. How can I `await` on an Rx Observable?
  10. What are the semantics of different RxJS subjects?
  11. Subject vs BehaviorSubject vs ReplaySubject in Angular
  12. Chaining Observables in RxJS
  13. Promise.all behavior with RxJS Observables?
  14. How to do the chain sequence in rxjs
  15. RxJS Promise Composition (passing data)
  16. RxJS sequence equivalent to promise.then()?
  17. Rxjs One Observable Feeding into Another
  18. RXJS Wait for all observables in an array to complete (or error)
  19. Angular 2 – Chaining http requests
  20. What are use cases for mergeMap operator?
  21. How to make one Observable sequence wait for another to complete before emitting?
  22. How to cancel a subscription in Angular2
  23. Is it good to call subscribe inside subscribe?
  24. What is the difference between Observable and a Subject in rxjs?
  25. How to ‘wait’ for two observables in RxJS
  26. Return an empty Observable
  27. Upgrading to Angular 10 – Fix CommonJS or AMD dependencies can cause optimization bailouts
  28. Property ‘catch’ does not exist on type ‘Observable’
  29. How to implement a global loader in Angular
  30. Observable Finally on Subscribe

Leave a Comment