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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）