So senden Sie benutzerdefinierte Ausnahme im Spring Web Flux Funktionalendpunkt zurück ⇐ Java

[Anonymous]

Ich bin neu in Spring Web Flux Umgebung. Während ich geübt habe, habe ich festgefahren, um benutzerdefinierte Ausnahmen zurückzugeben (sagen wir, wenn der Benutzer nicht gefunden wurde)
Ich möchte benutzerdefinierte Ausnahme in restControllerAdvice als globale Ausnahme ausführen. Unten ist der Code, den ich ausprobiert habe. < /P>

Code: Select all

public Mono getStudentByName(ServerRequest req) {
System.out.println("here here here");
Flux repoFlux = repo.findByFirstName(req.pathVariable("name"));
Flux handle = repoFlux.handle((stu,sink)->{
if(stu==null) {
System.out.println("USER NOT FOUND!!!");
System.out.println("NOT OK >"+stu);
sink.error(new UserNotFoundException("USER NOT FOUND"));
}
else {
System.out.println("OK OK OK OK");
System.out.println("OK > "+stu);
sink.next(stu);
}
});

return ServerResponse.ok().body(handle,Flux.class);
}

Ich habe diese hilfreiche Möglichkeiten verfolgt, Ausnahme im Spring -Webfluss zu behandeln. /> Warum Sink.Error < /code> nicht abgefeuert wird. Gibt es eine andere Möglichkeit, mit solchen Dingen umzugehen?