Весна реагирует на процесс больше моно в моно
У меня есть метод, как:
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();