epic中包含redux-observable和rxjs时出错

Question

我正在尝试创建一个使用rxfire从firestore获取数据的epic。每次发出一个值时，都需要调度一个操作。我的代码如下所示：

const fetchMenu = (action$, _state$) => {
  return action$.pipe(
    ofType(Types.FETCH_MENU_REQUESTED),
    flatMap((async ({ resID }) => {
      const firestore = firebase.firestore();
      const menuRef = firestore.collection('menus').where('resID', '==', resID);
      return collectionData(menuRef, 'id')
      .pipe(
        map(val => {
          return Creators.fetchMenuSuccess(val);
        })
      )
    }
    )),
  );
};

但是，我得到了错误Actions must be plain objects. Use custom middleware for async actions.

据我所知，pipe操作符将我的值包装在一个可观察的对象中，这就是我得到错误的原因，但我不确定该怎么做，以便它只返回操作。我对rxjs还是个新手，所以如果有任何帮助，我将非常感激。

Answer 1

您的flatMap回调是异步的，这意味着它返回的不是发出fetchMenuSuccess操作的可观察对象，而是解析为可观察对象的promise。Rx将自动展开promise，这意味着从该史诗返回的可观察值将发出可观察值，而不是订阅它们并发出自己的值。

删除async关键字应该可以解决这个问题。