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阵列的实际行动响应。

来源

2017-08-07 stelioschar

您好！你有没有尝试过测试你的重试？当没有其他所有东西和所有抽象？因为我或他们需要花费大量的时间来了解所有的事情，所以有人可能很难帮助你。 – jayphelps

@jayphelps感谢您的快速回复。问题似乎是，当使用'retry'或'retryWhen'重试从一开始执行整个操作时，不仅仅是重试内部ajax observable（在switchMap中）。我根据上面的例子做了很多测试，你可以看到[这里]（http://jsbin.com/hekener/36/edit?js,output），如果你试图改变重试次数（' .retry（3）'）或更改大理石响应（'response：[' - ＃a |''），您可以看到实际的帧是帧数和重试次数的乘积。 – stelioschar

我有一个类似的问题，我试图测试一个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|'));

我希望别人也就不那么哈克解决方案，但这种情况正在为我工作。

来源

2017-09-15 20:27:36

RxJS Redux-Observables测试重试当在一个史诗

回答

相关问题