2

在这里，我正在使用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服务的测试，以确保它在承诺拒绝时触发失败操作：

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 的无知？

4

1 回答 1

2

问题是您正在捕获 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放在 -- 注意 RxJScatch和 Promisecatch相似但不是一回事！

const logoutUserEpic = (action$) => action$
  .ofType(LOGOUT_USER)
  .mergeMap(() =>
    Observable.from(graphQl(AuthLogout))
      .mergeMap(() => Observable.of(
        receive(),
        push('/login')
      ))
      .catch((error) => Observable.of(failure(error)))
  )
于 2017-05-01T17:57:13.457 回答