将两个单声道与依赖项相结合

Question

我想创建一个SpringWebFlux服务，它将两个源的数据与一个依赖项相结合。我是Webflux的新手，所以我不知道怎么做。下面是一些伪代码来说明我要做的事情：

@Service
public class ServiceB {

    private RepositoryB repositoryB;
    private ServiceA serviceA;

    public Mono<BigDecimal> calculate(UUID id) {
        return repositoryB.findById(id)
                .flatMap(b -> serviceA.find(b.getId()))
                .flatMap((a, b) -> a + b);

    }

repositoryB的结果包括我想用serviceA查找的数据的标识符。至少我想处理这两个数据集。我可以使用什么方法代替第一个flatMap？

Answer 1

您可以返回reactor。util。作用第一个平面图中的元组

  public Mono<BigDecimal> calculate(UUID id) {
        return repositoryB.findById(id)
                .flatMap(b -> Mono.just(Tuples.of(b, serviceA.find(b.getId())))
                .flatMap((t) -> t.getT1().add(t.getT2()));

    }