tenho esse seguinte metodo:
private void searchLoja(List itensloja) {// itenslojar n estao sendo usados por enquanto pq to mockando os valores ali final var idsLojas = List.of(2, 69998787); valid(idsLojas).subscribe(); }
private Mono<Void> valid(List<Integer> lojas) {
return Flux.fromIterable(lojas)
.flatMap(id -> repository.existsByLojaId(id)
.flatMap(exists -> {
System.out.println(exists);
if (!exists) {
throw ExceptionUtils.buildException(
HttpStatus.NOT_FOUND,
"message.lojaid.not_found",
id.toString());
}
return Mono.empty();
}))
.then();
}
ele joga a exceção no console mas não vem na response, parece q não ta seguindo no fluxo e não há nenhum tratamento, eu chamo o metodo apenas
o repository vem mono, aqueles valores estao mockados um é true eoutro false, logo era pra jogar a exceção e vir 404, tem outro código q utiliza a mesma exceção e funciona então acho que é problema no meu webflux q fiz ali, alguma sugestão?
acredito que pela persistencia retornar o mono boolean desencadeie tudo, mas só funciona com mono boolean... o que faço? já tentei varias maeniras, não sei se é o subscribe ou o then ali que meio que não deixa ele subir a exception na response