如何在spring reactor中实现两个发布器的合二为一

Question

我已经实现了一个虚拟的反应存储库,但我正在为update方法苦苦挣扎：

@Override
public Mono<User> updateUser(int id, Mono<User> updateMono) {
    return  //todo with getUser
}

@Override
public Mono<User> getUser(int id) {
    return Mono.justOrEmpty(this.users.get(id));
}

一方面，我有传入的发布服务器mono updatemono ，另一方面，在mono.justorempty(This.users.get(id))期间，我有另一个发布服务器。

如何将其组合在一起，进行更新，并仅回馈一个发布者？

我想到的唯一一件事是：

@Override
public Mono<User> updateUser(int id, Mono<User> updateMono) {
    return  getUser(id).doOnNext(user -> {
        updateMono.subscribe(update -> {
            users.put(id, new User(id, update.getName(), update.getAge()));
            System.out.format("Updated user with id %d to %s%n", id, update);
        });
    });
}

是正确的吗？

Answer 1

请参阅关于查找正确运算符的参考指南

特别要注意的是，对于mono，您有和、when、then（注意，最后一个将在3.1.0中变为flatmap，而flatmap将变为FlatMapMany)

doonnext更多用于日志记录或统计数据收集等辅助操作。Subscribe内部订阅是另一种不良形式；通常，您需要flatmap或类似的文件。