RxJS Redux-Observables测试重试当在一个史诗
问题描述:
我正在努力如何测试retryWhen
运营商在redux-observable epic
。基于this example取自docs,我叉了this jsbin我试图测试的情况下,响应失败2次,之后,它返回一个有效的响应。RxJS Redux-Observables测试重试当在一个史诗
以下是部分代码。对于整个实施,请使用this jsbin
let RetryStrategy = attempts => attempts
.zip(Observable.range(1, 4))
.flatMap(([error, i]) => {
if (i > 3) {
return Observable.throw('Network error occured')
}
return Observable.timer(i * 1000)
})
const fetchFooEpic = (action$, store, call = indirect.call) =>
action$.ofType('FETCH_FOO')
.mergeMap(action =>
call(api.fetchFoo, action.payload.id)
.map(payload => ({ type: 'FETCH_FOO_FULFILLED', payload }))
.retryWhen(RetryStrategy)
.takeUntil(action$.ofType('FETCH_FOO_CANCELLED'))
.catch(error => of({
type: 'FETCH_FOO_REJECTED',
payload: error.xhr.response,
error: true
}))
);
describe('fetchFooEpic',() => {
...
it.only('handles errors correctly',() => {
const badResponse = { message: 'BAD STUFF' };
const response = { id: 123, name: 'Bilbo' };
expectEpic(fetchFooEpic, {
expected: ['-----a|', {
a: { type: 'FETCH_FOO_FULFILLED', payload: response }
}],
action: ['(a|)', {
a: { type: 'FETCH_FOO', payload: { id: 123 } }
}],
response: ['-#-#-a|', {
a: response
}, { xhr: { badResponse } }],
callArgs: [api.fetchFoo, 123]
});
});
...
});
如果您在jsbin中总是empty
阵列的实际行动响应。
答
我有一个类似的问题,我试图测试一个Angular HttpInterceptor,尝试三次尝试之间的延迟。正如您在评论中提到的那样,重试时每次错误后重新订阅观察值。这意味着如果你有一个可观察的错误(例如cold('#|')
),你将会在重试时总是得到一个错误,因为在每次重试时会重新订阅相同的可观察错误。
它看起来像一个黑客,但我创建了这个简单的类,按照给定的顺序订阅不同的observables。
class MultiObservable extends Observable<any> {
constructor(observables: Observable<any>[]) {
let subscriptionIdx = 0;
super((subscriber: Subscriber<any>) =>
observables[subscriptionIdx++].subscribe(subscriber));
}
}
在我的测试我使用它,如下所示:
const testObservable = new MultiObservable([
cold('#|', null, { status: 400 }),
cold('a|')
]);
next.handle.and.returnValue(testObservable);
const actual = interceptor.intercept(req, next);
expect(actual).toBeObservable(cold('---a|'));
我希望别人也就不那么哈克解决方案,但这种情况正在为我工作。
您好!你有没有尝试过测试你的重试?当没有其他所有东西和所有抽象?因为我或他们需要花费大量的时间来了解所有的事情,所以有人可能很难帮助你。 – jayphelps
@jayphelps感谢您的快速回复。问题似乎是,当使用'retry'或'retryWhen'重试从一开始执行整个操作时,不仅仅是重试内部ajax observable(在switchMap中)。我根据上面的例子做了很多测试,你可以看到[这里](http://jsbin.com/hekener/36/edit?js,output),如果你试图改变重试次数(' .retry(3)')或更改大理石响应('response:[' - #a |''),您可以看到实际的帧是帧数和重试次数的乘积。 – stelioschar