eine Mono <T> in einem Frühlings-Web-Controller Konsumieren

Question

ich derzeit versuche Reactor zu verstehen und eine Service-Methode Refactoring, die ein Optional<CompanyDetails> zurück Mono<CompanyDetails> anstelle des Reaktors zu verwenden:

public Mono<CompanyDetails> findOne(String id) { 
    CompanyDetails result = retrieveFromSomewhere(id); 
    return Mono.justOrEmpty(result); 
} 

Von meinem Verständnis dieser entweder empty() emittieren sollte oder just(result). ich verbrauchen den Dienst in einem Frühlings-Web-Controller wie folgt aus:

@RequestMapping(value = "{id}", method = RequestMethod.GET) 
public DeferredResult<CompanyDetails> getCompany(@PathVariable String id) { 
    final DeferredResult<CompanyDetails> result = new DeferredResult<>(); 
    companyService.findOne(id) 
      .consume(result::setResult); 
    return result; 
} 

Dies funktioniert gut, wenn ein Ergebnis gefunden wurde, aber wenn findOneempty() emittiert es läuft in ein Timeout. Ich könnte get() explizit anrufen und nach null suchen, aber das fühlt sich total falsch an.

Auch: Vor dem Refactoring, getCompany warf eine NotFoundException wenn kein Ergebnis gefunden wurde, ist das überhaupt möglich, oder bin ich auf dem falschen Weg vollständig?

Answer 1

Die Antwort gefunden: Zuerst stellte sich heraus, dass Reactor Mono eine toCompletableFuture -Methode hat und Spring MVC kann das auch anstelle von DeferredResult verwenden. Das Scheitern der CompletableFuture löst eine Ausnahme wie erwartet aus.

zum Scheitern verurteilt, hat Mono eine error statt empty auszusenden:

public Mono<CompanyDetails> findOne(String id) { 
    CompanyDetails result = retrieveFromSomewhere(id); 
    return Mono 
      .justOrEmpty(result) 
      .otherwiseIfEmpty(Mono.error(...)); 
} 

@RequestMapping(value = "{id}", method = RequestMethod.GET) 
public CompletableFuture<CompanyDetails> getCompany(@PathVariable String id) { 
    return companyService.findOne(id) 
      .toCompletableFuture(); 
} 

jetzt viel besser.