Spring Webflux:嵌套平面图替代

Question

我有一个场景，其中第二个单声道依赖于first stMono和ThridMono调用依赖于第二个单声道输出。

我写的代码如下。

  firstMono.flatMap{

    val secondMono = callWebservice(firstMono)

    val thrirdMono = secondMono.flatMap { secondMonoResponse ->
        if (secondMonoResponse.getName.equals("ABC")) {
            callAnotherWebService(secondMon)
        } else {
            secondMono
        }
    }
}

我怎样才能避免这里的第二个平面图？。有没有办法在没有嵌套平面图的情况下做到这一点。我应该只在满足条件的情况下调用serrdMono。

Answer 1

答案可能会有所不同，具体取决于每个Mono的确切性能。然而，当我查看代码片段时，我没有看到在第一个Mono上调用flatMap{}的意义，所以它可能看起来如下：

callWebservice(firstMono)
  .flatMap { secondMonoResponse ->
    if (secondMonoResponse.name == "ABC" ) {
      callAnotherWebService(secondMono)
    } else {
      secondMono
    }
  }

另一方面，这里也可以使用. zip方法:

val secondMono = callWebservice(firstMono)
Mono.zip(firstMono, callWebservice(firstMono))
  .flatMap { 
    val secondMonoResponse = it.t2
    if (secondMonoResponse.name == "ABC" ) {
      callAnotherWebService(secondMono)
    } else {
      secondMono
    }
  }

注意：我已经删除了val shirdMono，因为上面的代码片段不会编译，因为返回类型是Unit（而不是Mono）。