Как написать модульный тест для эффекта, который после n раз возвращает правильный ответ?

Я должен написать модульный тест для этого эффекта, который вызывает сервис каждые 1 секунду, когда он идет по ошибке. Мне нужно проверить, например, что после 3-х раз звонков в службу я получу хороший ответ.

Я пробовал как-то протестировать, но безрезультатно.

Это эффект, который я должен проверить:

@Effect()
  updateEffect$ = this.actions$.pipe(
    ofType(featureActions.ActionTypes.UPDATE_PRODUCT),
    switchMap((action: UpdateProduct) =>
      this.productService.getProducts().pipe(
        retryWhen((attempts) => attempts.pipe(delay(1000))),
        map((productsResponse: Products) =>
          productsResponse
            ? new featureActions.LoadProductSuccess(productsResponse)
            : new featureActions.LoadProductError(productsResponse)
        )
      )
    )
  );

Это модульный тест, который я сделал, чтобы увидеть успешный сценарий. Я хочу проверить логику перезагрузки.

 it('should return UpdateProduct if service response success ', () => {
    const action = new UpdateProduct('123456');
    const completion = new LoadProductSuccess(productsResponseMock);

    actions$ = hot('-a-', { a: action });
    const response = cold('-b', { b: productsResponseMock });
    const expected = cold('--c', { c: completion });

    productService.getProducts.and.returnValue(response);
    expect(effects.updateEffect$).toBeObservable(expected);
  });