Наблюдаемая избыточность.map вызывает остановку потока действий
Я новичок в наблюдении за редуксом. Я добавил.mapTo(actions.updateDeviceToken({})), и это сработало.
Однако successFetchNewDiaries(данные) не работает. .mapTo(actions.updateDeviceToken({})) прекратить запуск SUCCESS_FETCH_NEW_DIARIES.
Что случилось?
до
const fetchNewDiariesEpic = (action$: Observable<Action>, store: any) =>
action$.ofType(actions.FETCH_NEW_DIARIES)
.exhaustMap(() => {
return request({
method: 'get',
url: 'diaries.json',
params: { page: 1 },
})
.map(data => normalize(camelcaseKeysDeep(data), [diarySchema]))
.map(data => actions.successFetchNewDiaries(data))
.catch((errorMessage: string) =>
Observable.of(actions.failFetchNewDiaries({ errorMessage })));
})
после
const fetchNewDiariesEpic = (action$: Observable<Action>, store: any) =>
action$.ofType(actions.FETCH_NEW_DIARIES)
.exhaustMap(() => {
return request({
method: 'get',
url: 'diaries.json',
params: { page: 1 },
})
.map(data => normalize(camelcaseKeysDeep(data), [diarySchema]))
.map(data => actions.successFetchNewDiaries(data))
.mapTo(actions.updateDeviceToken({})) // NEW LINE.
.catch((errorMessage: string) => Observable.of(actions.failFetchNewDiaries({ errorMessage })));
})
до FETCH_NEW_DIARIES FETCH_PROCEDURES SUCCESS_FETCH_NEW_DIARIES SUCCESS_FETCH_PROCEDURES
после FETCH_NEW_DIARIES FETCH_PROCEDURES UPDATE_DEVICE_TOKEN SUCCESS_FETCH_PROCEDURES
Где находится SUCCESS_FETCH_NEW_DIARIES?