从其他 epics 中调用 epics

Question

首先是这个很棒的图书馆的许多道具！不过，我仍在为一个用例而苦苦挣扎。我想先调用另一个史诗，等它完成后再继续当前的史诗。假设我有一个用户可以更改内容的表单。在将其他数据加载到表单之前，我想先保存当前的更改。对此有什么想法吗？

Answer 1

听起来像你想要的：如果一部史诗想要开始另一部 epics 作品并且在继续之前等待它完成。

一种方法是（使用假名），当收到初始操作 LOAD_OTHER_DATA 时，您会立即开始收听单个 SAVE_FORM_FULFILLED，这表示表单已保存（我们将踢稍等片刻）。收到后，我们 mergeMap（或 switchMap，在这种情况下无关紧要）进入我们的调用以加载其他数据 loadOtherDataSomehow() 并执行通常的业务。最后，开始实际保存我们正在等待的表单的技巧是在整个链的末尾添加一个 startWith()——这将发出并分派操作以实际保存表单。

const saveFormEpic = (action$, store) =>
  action$
    .ofType('SAVE_FORM')
    .switchMap(() =>
      saveFormSomeHow(store.getState().formDataSomewhere)
        .map(details => ({
          type: 'SAVE_FORM_FULFILLED'
        }))
    );

const loadOtherDataEpic = action$ =>
  action$
    .ofType('LOAD_OTHER_DATA')
    .switchMap(() =>
      action$.ofType('SAVE_FORM_FULFILLED')
        .take(1) // don't listen forever! IMPORTANT!
        .mergeMap(() =>
          loadOtherDataSomeHow()
            .map(otherData => ({
              type: 'LOAD_OTHER_DATA_FULFILLED',
              payload: otherData
            }))
        )
        .startWith({
          type: 'SAVE_FORM'
        })
    );

您没有提到您的加载和保存是如何工作的，所以这只是伪代码，您需要根据您的用例进行修改。

Answer 2

@jayphelps，我只想说谢谢你回答的所有问题，他们确实帮助我解决了很多问题。

我试图提出我的问题，发现你已经在这里回答了它，并设法使用你的样本解决了我的问题。

我的例子has/had 2 说明我want/ed 互相调用:

const requestNameEpic = action$ =>
  action$.ofType("REQUEST_NAME")
    .switchMap(({id}) =>
      Observable.of(`name returned by 'ajax' call, using id: ${id}`) // Ajax simulation
        .delay(1000)
        .map(name => ({type: "LOAD_NAME", name}))
    );

const requestAgeEpic = action$ =>
  action$.ofType("REQUEST_AGE")
    .switchMap(({name}) =>
      Observable.of(`age returned by 'ajax' call, using name: [${name}]`)
        .delay(1000)
        .map(age => ({type: "LOAD_AGE", age}))
    );

我设法解决它的方法是使用：

const requestDetailsEpic = action$ =>
  action$.ofType("LOAD_NAME")
    .map(({name}) => ({type: "REQUEST_AGE", name}));

所以调度 REQUEST_NAME 也会调度 REQUEST_AGE，但那样我将永远无法只调度 LOAD_NAME。

我重构了您的示例以获得：

const requestDetailsEpic = action$ =>
  action$.ofType("REQUEST_DETAILS")
    .switchMap(({id}) =>
      action$.ofType("LOAD_NAME")
        .take(1) // don't listen forever! IMPORTANT!
        .map(({name}) => ({type: "REQUEST_AGE", name}))
        .startWith({type: "REQUEST_NAME", id})
  );

再次感谢您在 redux-observable 上所做的所有出色工作以及所有社区的支持。

从其他 epics 中调用 epics

Invoking epics from within other epics

reactjs

redux

rxjs

redux-observable