How can I handle errors in RxJS?

How can I handle errors in RxJS?

In RxJS, you can handle errors using operators like catchError and retry. Would you like an example?

Yes, please provide an example of using catchError.

Sure! Here's a simple example:

import { of, throwError } from 'rxjs';
import { catchError } from 'rxjs/operators';

const source$ = throwError('Error!');

source$.pipe(
  catchError(err => {
    console.error(err);
    return of('Error handled!');
  })
).subscribe(console.log);

This will log the error and return a fallback value.

What about using retry? How does that work?

The retry operator allows you to re-subscribe to the observable a specified number of times before failing. Here's an example:

import { of, throwError } from 'rxjs';
import { retry, catchError } from 'rxjs/operators';

const source$ = throwError('Error!');

source$.pipe(
  retry(2),
  catchError(err => of('Error handled after retries!'))
).subscribe(console.log);

This will attempt to re-subscribe twice before handling the error.