redux-observable epics 的测试错误处理

Question

这里我使用 redux-observable 并且在测试错误处理时遇到了一些问题。

查看以下注销用户史诗：

const logoutUserEpic = (action$) => action$
    .ofType(LOGOUT_USER)
    .mergeMap(() =>
        Observable.from(
            graphQl(AuthLogout)
                .catch((error) => failure(error))
        )
        .mergeMap(() => Observable.of(
                receive(),
                push('/login')
            )
        )
    )

这是一个模拟 graphQl 服务的测试，以确保它在 promise 拒绝时触发失败操作：

it('should return the error action', () => {
    const error = Error('fail')
    request.graphQl = () => Promise.reject(error)

    const action$ = ActionsObservable.of((logoutUser()))

    return logoutUserEpic(action$)
    .toArray()
    .forEach((actions) => {
        expect(actions).toEqual([{
            meta: { isFetching: false },
            payload: error,
            type: FAILURE
        }])
    })
})

在测试中，它调度在 mergeMap 中展平的操作，而不是 catch 中预期的失败操作。

像这样设置错误处理是否有效，或者我是否在展示我对 RxJs 的笨拙？

Answer 1

问题是您捕获了 Promise 本身的错误，然后您的 mergeMap 忽略了 Promise 的结果，因此您丢弃了 failure(error)（可能是一个错误操作)

const logoutUserEpic = (action$) => action$
    .ofType(LOGOUT_USER)
    .mergeMap(() =>
        Observable.from(
            graphQl(AuthLogout)
                .catch((error) => failure(error))
                // If there is an error, you caught it and transformed it
                // instead into a failure(error) down the success path
        )
        // If there was an error, it is now no longer an error and this
        // mergeMap will just throw that failure(error) away
        .mergeMap(() => Observable.of(
                receive(),
                push('/login')
            )
        )
    )

相反，您应该使用 RxJS 捕获错误，在这种情况下将其放在 mergeMap 之后——请注意 RxJS 的 catch 和 Promise catch 相似但不相同东西！

const logoutUserEpic = (action$) => action$
  .ofType(LOGOUT_USER)
  .mergeMap(() =>
    Observable.from(graphQl(AuthLogout))
      .mergeMap(() => Observable.of(
        receive(),
        push('/login')
      ))
      .catch((error) => Observable.of(failure(error)))
  )

redux-observable epics 的测试错误处理

Testing error handling for redux-observable epics

redux

rxjs

rxjs5

reactivex

redux-observable