0
私のストアには、保留中のネットワーク要求を含むキューがあります。 アクションATTEMPT_FLUSH
がエミュレートされている場合は、に続けて、にリクエストを送信します。 しかし、そのうちの1つが失敗してATTEMPT_FLUSH_CANCELLED
を発した場合、次のものは試みられません(次のATTEMPT_FLUSH
で再試行するまで)。1つが失敗したときに、Ajaxコールのシーケンスをキャンセルします。
は、ここで私はこれまで
export const attemptFlushEpic = (action$, store) =>
action$
.ofType(ATTEMPT_FLUSH)
.mergeMap(() => Observable.from(store.getState().queue)) // state.queue is an array
.concatMap(action =>
Observable.ajax(action.url)
.map(response => removeFromQueue(action))
.catch(err => Observable.of(attemptFlushCancelled())));