java - 作为 if 语句的结果，如何在另一个 react 流中使用一个 react 流

Question

我必须将一种方法重构为响应式，该方法返回 Enum.VALUE。该方法的工作原理类似于从一个 if 语句到另一个 if 语句的过滤器。我使用 Pair 来实现它，并且当某些 if 语句返回 true(在 map() 方法上)或通过所有元素的路径时，代码会制动链条。它可以工作，但是有两个辅助方法在 map() if 语句内部使用，它们实际上是阻塞的，所以我必须使它们非阻塞。辅助方法One返回boolean，并且每次调用该方法时都必须调用它。下面是示例代码:

public Mono<Enum> method(String param) {
return Mono.just(param)
   .map(
      //filter if-statement
    )
 .map(
      //filter if-statement
    )
 .map(
    pair -> {
       if (auxiliaryMethodOne(param)) {
      //filter if-statement
        }
      }
    )
 .map(
      //filter if-statement
    )
}

private Mono <Boolean> auxiliaryMethodOne(String param) {
    //some logic returns Mono<Boolean>
}

Answer 1

您可以使用Mono#filterWhen:

myMono.filterWhen(pair -> auxiliaryMethodOne(param))