Redux-observable和rxjs中的史诗错误

问题描述

我正在尝试创建一个史诗般的史诗，该史诗使用rxfire从firestore中获取数据。在每次发射值时，都需要调度一个动作。我的代码如下：

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还是有点陌生​​，所以我们将不胜感激。

解决方法

您的flatMap回调是异步的，这意味着它没有返回发出fetchMenuSuccess动作的可观察对象，而是返回了解析为可观察对象的承诺。 Rx会自动取消承诺，这意味着从此史诗中返回的可观察对象将发出可观察对象，而不是订阅它们并产生其自身的值。

删除async关键字可以解决此问题。