fin blog embed

wrap-observable-request.js

export const wrapObservableRequest = (type, observable, args = {}) =>
  observable
    .map(result => {
      return { args, type, readyState: SUCCESS, data: result.data };
    })
    .catch(error => Observable.of({ args, type, readyState: FAILURE, error: getError(error) }))
    .startWith({ args, type, readyState: REQUEST });

// Which can be used in an epic like this:
const postEpic = (actions$) => {
  return actions$
    .ofType(TRIGGER_FETCH)
    .flatMap(action => {
      return wrapObservableRequest(FETCH_POSTS, Observable.fromPromise(
        fetch(`https://www.reddit.com/r/${action.subreddit}.json`)
          .then(
            response => response.json(),
            error => console.log('An error occured.', error)
          )
        ))
    })
}