console.clear();

​

const { of, concat } = Rx.Observable;

​

const AppConfig = {

  serverUrl: () => '/whatever'

};

​

// mocks, either success or fail

const ajax = {

  getJSON: url => of({ url }).delay(100)

  //getJSON: url => Rx.Observable.throw({ url }).delay(100)

};

​

​

const finishLoadingThings = payload => ({ type: 'finishLoadingThings', payload });

const sendNotification = payload => ({ type: 'sendNotification', payload });

​

const loadThingsEpic = action$ => {

​

  return action$.ofType('LOAD_THINGS')

    .mergeMap(({things}) => {

      const requestURL = `${AppConfig.serverUrl()}/data/things`;

      return ajax.getJSON(requestURL).switchMap(response => {

        return concat(of(finishLoadingThings(response)),

                      of(sendNotification('success')));

      });

    })

    .catch(e => {

    console.error('caught this:', e);

      return concat(of(finishLoadingThings({ things: {} })),

                    of(sendNotification('error')));

    });   

}

​

const reducer = (state, action) => {

  console.log(action);

};

​

// redux/configureStore.js

​

const { Provider } = ReactRedux;

const { createStore, applyMiddleware } = Redux;

const { createEpicMiddleware } = ReduxObservable;

​

const epicMiddleware = createEpicMiddleware(loadThingsEpic);

​

const store = createStore(reducer,

  applyMiddleware(epicMiddleware)

);

​

store.dispatch({ type: 'LOAD_THINGS' });

​