Durante el reintento de prueba unitaria, la respuesta del simulacro parece almacenada en caché, o lo más probable es que esté haciendo algo mal.

Estoy tratando de solicitar algo, si ocurrió un error, vuelva a intentarlo dos veces con un retraso de 1 segundo.

 public Mono<Object> someMethod(String someParam) { return someInjectedService.doSomething(someParam) .doOnError(ex -> System.out.println(ex + ": " + System.currentTimeMillis())) .retryWhen(Retry.fixedDelay(2, Duration.ofSeconds(1)).filter(ex -> ex instanceof SomeCustomException)) .doOnSuccess(result -> doSomethingOnSuccess(result)); }

Mi prueba:

 @Test void testshouldRequestThrice_whenErrorOccurs() { // Given String someParam = "testParam"; when(someInjectedService.doSomething(someParam)) .thenReturn(Mono.error(new SomeCustomException("SomeCustomException"))) // 1st response .thenReturn(Mono.error(new SomeCustomException("SomeCustomException"))) // 2nd response .thenReturn(Mono.just("SomeValidResponse")); // 3rd valid response // When var result = testService.someMethod(someParam).block(); // Then // Initial request, followed by two retries verify(someInjectedService, times(3)).doSomething(someParam); }

aquí someInjectedService es un simulacro. Mi plan era devolver una excepción dos veces y, en la tercera solicitud, devolver una respuesta válida. Pero lo que obtengo es:

org.mockito.exceptions.verification.TooFewActualInvocations: someInjectedService.doSomething("testParam");

Se busca 3 veces: -> en shouldRequestThrice_whenErrorOccurs(test.java:138)

Pero fue 1 vez:

Si bien veo 3 impresiones del .doOnError(ex -> System.out.println(ex + ": " + System.currentTimeMillis())) , siento que la solicitud real se envía solo una vez.

Gracias de antemano,