-
0 votesanswersviews
TypeError:您提供了一个无效的对象,其中包含一个流
以下代码有效 . 它执行ajax请求,然后一次调用2个操作: export const loadThingsEpic = action$ => { return action$.ofType(LOAD_THINGS) .mergeMap(({things}) => { const requestURL = `${AppConfig.serverUrl()}/d... -
0 votesanswersviews
将redux-thunk与redux-observable混合使用
我有一个使用redux-thunk的应用程序,并想尝试redux-observable . 目前我有一个thunk动作创建者执行以下操作: const initState = () => { return dispatch => new Promise((resolve,reject)=>{ //these each return axios promis... -
28 votesanswersviews
redux-observable - 在单个史诗中发送多个redux动作
我正在寻找在单个Epic of redux-observable 中间件中调度多个redux动作的方法 . 我们假设我有以下史诗 . 每当发生 SEARCH 事件时,Epic都会从后端加载数据并发送 RESULTS_LOADED 动作 . searchEpic = (action$) => action$ .ofType('SEARCH') .mergeMap( ... -
1 votesanswersviews
具有redux-observable的Rxjs . 重复动作
我有这样的史诗: export const fetchCharacter = (id) => ajax({ url: `https://swapi.co/api/people/${id}` }) .map(response => fetchCharacterSuccess(response.body)) .catch(error => Observable.o... -
3 votesanswersviews
如何从redux-observable调度多个动作?
我想从一个redux-observable史诗派遣多个动作 . 我该怎么做?我最初开始 const addCategoryEpic = action$ => { return action$.ofType(ADD_CATEGORY_REQUEST) .switchMap((action) => { const db = firebase.firestore() ... -
0 votesanswersviews
redux-observable派遣行动
我需要使用 redux-observable 以某种顺序发送一些动作,但是,它只需要最后一次动作即可发送 . 请看例子: export const fetchClientsEpic = (action$, { dispatch }) => action$ .ofType(fetchClients) .mapTo(fetchClientsPending(true)) ... -
1 votesanswersviews
如何在组件中订阅epic的输出操作流
我正在重构 loadInstruments thunk到redux-observable epic中,因为它正在做越来越多的异步内容以及我需要取消等等(来自教程的典型wiki搜索场景) . 这是我的组件使用这个thunk的方式(它是通过 mapDispatchToProps 提供的) this.props.loadInstruments(queryParams).then(...) Thunk... -
1 votesanswersviews
等待在redux-observable中异步调度操作
我有一个epic,它调度一个由redux中间件处理的动作,一旦调度动作就会返回一个promise . 史诗看起来大致如下: const myEpic = action$ => action$.pipe( ofType(SAVE_ACTION), switchMap(action => [ saveData(action.payload) ]) )... -
1 votesanswersviews
RXJS Redux Observable - 如何合并新流?
我们最近选择了Redux Observable,这是管理高级动作编排的好方法 . 我最近遇到的一个问题是响应数据提取的结果 . 我们有一个通用服务函数,它返回一个RXJS可观察对象 . 通常我们选择我们需要和订阅的数据 . 我认为这对于redux-observable来说是相当自然的 . 在Epic上使用MapTo,并使用后续选择返回RXJS观察者 . 据我所知,Redux-observable不... -
4 votesanswersviews
在redux-observable中 - 如何在不返回该操作的值的情况下“中流”调度操作?
我到处搜索,找不到以下的答案...... 在我的addItemEpic中,我想在发送ajax请求之前调度“加载”操作 - 我不希望返回操作的值 - 我只想做动作然后返回ajax响应 . 这可以通过store.dispatch()轻松实现,如下所示: export const addItemsEpic = (action$, store) => action$.ofType(ADD_ITE... -
2 votesanswersviews
Rxjs解析可观察和合并结果的数组
我订阅了一个可观察数组的问题 . 在我的例子中,我有一个ID数组,我需要从我的状态获取所有ID,将所有结果合并到一个observable中并订阅该observable . 我需要我的订阅者最终会获得一系列已解析的observable . 此外,我需要保持此订阅打开,所以如果我的一个内部可观察的更改我的订阅者将通过它通知 . 这是我的代码: getTransactionsByIDs(transact... -
0 votesanswersviews
史诗中的功能是无序发射,我无法理解为什么
*已解决问题在于我如何创建和响应firebase回调创建的observable . 我的firebase回调中也有太多东西在进行 . 我最终使用firebase promise结构将它拆分了一些:https://firebase.googleblog.com/2016/01/keeping-our-promises-and-callbacks_76.html并在现在称为firebaseAPI.ch... -
3 votesanswersviews
从Redux Observable返回一个Promise
也许我正在考虑这个错误,但是我使用redux-thunk的一个常见模式是返回一个promise,这样当一些事情完成或失败时我可以在容器对象中执行一些额外的操作 . 以Thunk为例: 动作创作者: const action = ({ data }) => (dispatch) => fetch(`some http url`) .then(response =>... -
1 votesanswersviews
与redux-mock-store一起使用时,redux-observable流中的重复操作
我打开了一个问题,但万一我做错了: 使用jest和redux-mock-store编写单个测试时,一切都按预期工作 . 但是如果我多次使用mockStore(在同一个测试中,甚至在另一个测试中),那么在任何创建的商店中调度的动作将在observable中多次发送(但在store中只发送一次,如store.getActions()状态 . 这是一个复制回购:https://framagit.org/... -
0 votesanswersviews
当source $是单个动作时,从redux-observable epic中发出2个值
我试图从给定单一来源$动作的史诗中返回2个单独的值 . 但是 - 似乎我只能通过显式订阅内部Observable来做到这一点 . 我的史诗目前看起来像这样: export const orderItemEpic = action$ => action$.ofType(ORDER_ITEM) .switchMap(action => Observable.of( ...