使用redux observate执行XHR然后调度成功/失败

将一个基于redux的大型代码库移到redux observate,我正在努力找出史诗的语义,它将:

1. 听负载动作
2. 执行XHR
3. 发送适当的成功或失败操作

到目前为止我得到的是:

export function editEpic(action$, unusedStore, { xhrClient }) {
  return action$
    .ofType(LOAD_ACTION)
    .map(({ apiParams, operationId }) => {
      // xhrClient is an object with methods on it that
      // return a Promise of the data
      const editOperation = xhrClient[operationId];

      // call the api now
      return editOperation(apiParams);
    })
    .map(result => {
      return { type: SUCCESS_ACTION, result };
    })
    .catch(error => {
      // We never get here..
      return { type: FAILURE_ACTION, error };
    });
}

当API调用成功时,这种方法就可以正常工作,但是如果承诺因错误而被拒绝,则 catch 操作永远不会被调用。

有人能给我指个正确的方向吗?我们正在使用:

• redux-observable@0.18.0
• rxjs@5.5.11