Наблюдаемая избыточность.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?

0 ответов

Другие вопросы по тегам