redux-observable 和 rxjs 的史诗错误

Question

我正在尝试创建一个使用 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 运算符将我的值包装在一个可观察对象中，这就是我收到错误的原因，但我不确定该怎么做才能仅 returns 动作。我对 rxjs 还是有点陌生，所以非常感谢任何帮助。

Answer 1

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

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

redux-observable 和 rxjs 的史诗错误

Error in epic with redux-observable and rxjs

firebase

react-redux

rxjs

redux-observable

rxfire