Spring 在单声道中反应处理更多单声道

Question

我有这样的方法：

public Mono<Double> calculate(OperandDto dto) {
    Mono<Double> dbResult1Mono = mongoReactRepo.findByMyLogic(dto);
    Mono<Double> dbResult2Mono = mongoReactRepo.findByMyOtherLogic(dto);

    // ? Multiply these results (dbResult1Mono * dbResult2Mono), and return with Mono<Double> ?
}

我想以反应方式将 2 个 Mono 对象的结果与 return 一个新的 Mono 对象相乘。

有人可以帮我怎么做吗？

谢谢

Answer 1

您可以使用 Flux.combineLatest():

    Mono<Double> dbResult1Mono = Mono.just(2d);
    Mono<Double> dbResult2Mono = Mono.just(5d);

   return Flux.combineLatest(dbResult1Mono, dbResult2Mono, (r1, r2) -> r1 * r2).next();

Spring 在单声道中反应处理更多单声道

Spring react process more mono in mono

spring

reactor

spring-webflux