модульный тест rxjs с повторной попыткой

Question

У меня есть следующий метод, и мне нужно написать несколько юнит-тестов для него, но я не могу смоделировать ответ, я пытался использовать TestScheduler, но он не был успешным, любая помощь будет оценена.Я использую шутку.

protected waitForResponse(id: number, requestId: string) {
    return this.service.getData(id, requestId)
      .pipe(
        mergeMap((resp: ResponseModel) => {
          if (resp.status !== 'WAITING') {
            return of(resp);
          }
          return throwError(resp);
        }),
        retryWhen(errors => errors.pipe(
          concatMap((e, i) =>
            iif(
              () => i > 11,
              // max number of 11 attempts has been reached
              throwError(new HttpErrorResponse({status: HttpStatusCode.TOO_MANY_REQUESTS})),
              // Otherwise try again in 5 secs
              of(e).pipe(delay(5000))
            )
          )
          )
        )
      );
  }

Answer 1

Мне удалось получить решение с помощью следующей функции:

const mockFunction = (times) => {    
    let count = 0;
    return Observable.create((observer) => {
        if (count++ > times) {
            observer.next(latestData);
        } else {
            observer.next(waitingData);
        }
    });
};

И я использовал шутку, чтобы шутить с возвращаемым значением:

jest.spyOn(service, 'getData').mockReturnValue(mockFunction(4));

Это вернет 4 ожидающих ответа и последний из них.

jest.spyOn(service, 'getData').mockReturnValue(mockFunction(20));

Любое число выше 11 приведет к превышению моего максимального числа попыток