如何解决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
关键字可以解决此问题。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。