Весна реагирует на процесс больше моно в моно

У меня есть метод, как:

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 и вернуть новый объект Mono реактивным способом.

Кто-нибудь может мне помочь, как это сделать?

Спасибо

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();
Другие вопросы по тегам