Mám servisní vrstvy pomocí Jaře Webflux a reaktor a já jsem psát unit test. Byl jsem schopen otestovat dobrý scénář odezvy, ale nejste si jisti, jak otestovat onErrorResume()
pomocí StepVerifier. Také, prosím, dejte mi vědět, jestli existuje lepší způsob zpracování výjimek v mém řadič(e.g: použití switchIfEmpty()
)
Tady je moje metoda regulátor
public Mono<SomeType> getInfo(Integer id) {
return webClient
.get()
.uri(uriBuilder -> uriBuilder.path())
.header("", "")
.header("", "")
.header("", "")
.header(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE)
.retrieve()
.bodyToMono(POJO.class)
.onErrorResume(ex -> {
if (ex instanceof WebFaultException)
return Mono.error(ex);
return Mono.error(new WebFaultException(ex.getMessage(), "Error on API Call", HttpStatus.INTERNAL_SERVER_ERROR));
});
}
}