What are some examples of using redux-observable?

What are some examples of using redux-observable?

Redux-Observable is a middleware for Redux that allows you to handle asynchronous actions using RxJS. One common example is handling API calls.

Can you show me a code example for making an API call?

Sure! Here's a simple example:

import { ofType } from 'redux-observable';
import { ajax } from 'rxjs/ajax';
import { map, mergeMap } from 'rxjs/operators';

const fetchDataEpic = action$ => action$.pipe(
  ofType('FETCH_DATA'),
  mergeMap(action => 
    ajax.getJSON(`https://api.example.com/data`).pipe(
      map(response => ({ type: 'FETCH_DATA_SUCCESS', payload: response }))
    )
  )
);

This epic listens for a FETCH_DATA action and makes an API call.

What if the API call fails?

You can handle errors by using the catchError operator. Here's an updated example:

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

const fetchDataEpic = action$ => action$.pipe(
  ofType('FETCH_DATA'),
  mergeMap(action => 
    ajax.getJSON(`https://api.example.com/data`).pipe(
      map(response => ({ type: 'FETCH_DATA_SUCCESS', payload: response })),
      catchError(error => of({ type: 'FETCH_DATA_ERROR', payload: error }))
    )
  )
);

This will dispatch a FETCH_DATA_ERROR action if the API call fails.