两个单声道与条件的组合

Question

我想根据一些条件将结果从两个单声道组合起来。这两个单声道都是网络客户端调用的结果：

• 第一个是期望快速响应的单个呼叫。
• 第二个是几个响应缓慢的电话的组合。

如果第一个单声道的结果满足某些条件，则“取消”第二个单声道的想法可以节省时间并避免不必要的网络调用。如果第一个单声道的结果不够，请使用第二个单声道。

一个静态编程语言代码示例来解释我的想法：

fun getResult(): Mono<Result> {

    val trivialResultMono: Mono<Result> = webClient.getResult()

    val nonTrivialResultMono: Mono<Result> = webClient
            .getResult()
            .flatMap { webClient.getResult1(it) }
            .flatMap { webClient.getResult2(it) }
            .flatMap { webClient.getResult2(it) }

    //here I need to check if trivial result satisfies some condition,
    //for example trivialResult.size > 5 if it's true I just return
    //trivialResultMono from getResult() function, 
    //it it's false something like this:
    return Mono.zip(trivialResultMono, nonTrivialResultMono) { trivialResult, nonTrivialResult ->
        trivialResult + nonTrivialResult
    }

}

更新：

更清楚的是，让我们假设平凡的结果在1秒内出现，非平凡的结果在2秒内出现。我想在1秒钟内得到我的最终结果，以防<代码>平凡的结果。大小

仅使用单声道。zip（TritileResultMono，nonTrivialResultMono）我总是会在2秒钟内得到最终结果。

使用html" target="_blank">过滤器开关，如果trivialResult.size，则需要1秒




Answer 1

您可以使用flatMap和map来实现这一点：

trivial.flatMap(trivialResult -> {
  if (trivialResult.size > 5) {
    return Mono.just(trivialResult);
  } else {
    return nonTrivial.map(nonTrivialResult -> trivialResult + nonTrivialResult);
  }
});

Answer 2

您可以过滤平凡的ResultMono，并应用switchIfEmpty操作符

return trivialResultMono
        .filter(trivialResult -> trivialResult.size > 5)
        .switchIfEmpty(Mono.zip(...))

合并方法更新：

Mono<Result> zipResultMono = Mono.zip...

return Flux.merge(
        trivialResultMono.map(trivialResult -> Tuples.of(1, trivialResult)),
        zipResultMono.map(zipResult -> Tuples.of(2, zipResult)))
        .filter(tuple ->
                (tuple.getT1().equals(1) && tuple.getT2().size > 5) ||
                        tuple.getT1().equals(2))
        .next()
        .map(Tuple2::getT2);

如果zipResult的大小始终大于5，则可以跳过转换为Tuple2