第一个单声道完成后致电单声道并返回第一个单声道的结果

Question

我想在WebFlux环境中执行两个业务操作，仅在第一个操作成功之后，第二次操作才会发生。第二个完成后，我想返回第一个操作的结果。第二个操作称为org.springframework.web.reactive.function.client.webclient。这是我到目前为止尝试的：

public Mono<ResponseEntity<Resource>> callOperations(){
   return service.operation1()
          .flatMap(resource -> {
                   service.operation2();
                   return resource;
           })
          .map(ResponseEntity::ok);

}

当时我还尝试了并订阅，但是我无法让网络客户执行​​呼叫并返回service.operation.operation1。我该怎么办？

Answer 1

您需要使用反应式操作员构建流程，并让WebFlux订阅它。在您的片段中，没有订阅 service.operation2（）

public Mono<ResponseEntity<Resource>> callOperations(){
   return service.operation1()
          .flatMap(resource -> {
                   return service.operation2()
                       .thenReturn(resource);
           })
          ...

}

Answer 2

正确的成语正在调用 mono.delayuntil（）：

​

public Mono<ResponseEntity<Resource>> callOperations(){
   return service.operation1()
          .delayUntil(service.operation2())
          ...
}