调用第二个Mono而不丢失第一个Mono的结果的最佳方法是什么？

Question

我有需要与两个反应性依赖项交互的代码——保存到数据库和发布到流，每个都返回Mono实例。在这之后，我需要做更多的处理——所有这些都使用我开始时的原始对象，类似这样：

val myObject = Mono.just(“thing”);
myObject.flatMap(repository::save)
        .flatMap(stream::publish)
        .map(obj -> moreProcessing(obj));

但问题是，repository.save不会返回我感兴趣的对象的Mono，stream.publish也不会返回。

我可以实现我想要的东西，比如：

myObject.flatMap(obj -> repository.save(obj).then(Mono.just(obj))
        .flatMap(obj -> stream.publish(obj).then(Mono.just(obj))
        .map(obj -> moreProcessing(obj));

i、 e.映射到依赖函数只是为了得到它们的行为，然后再直接映射回来，但这似乎很奇怪-好像我可能缺少了更好的方法来使用API，它没有给出我在类型之间映射的提示，因为这不是我真正使用的flatMap。

我也可以选择这样的方式：

myObject.flatMap(obj ->
            repository.save(obj)
                .flatMap(x -> publisher.stream(obj))
                .map(x -> moreProcessing(obj)));

但这似乎也不是一个好方法，因为即使在相对简单的情况下，它也会导致难以维护的代码。

思想？

Answer 1

避免失去任何推荐人的一种方法可能是这样的：

Mono<User> monoUser = userRepository.findByUsername(username)
                                .filter(u -> validatePassword(pass, u.getPassword()));

Mono<Clinic> monoClinic = monoUser.flatMap(u -> clinicRepository.findByUserId(u.getId()));
        
return Mono.zip(monoUser, monoClinic, (u,c) -> proccess(u, c)); 

第一单声道返回用户，第二单声道使用第一单声道返回的用户并返回诊所，返回的单声道（第三单声道）使用第一单声道的输出和第二单声道的输出来创建不同的对象（通过使用用户和诊所的过程方法返回）

Answer 2

你试过吗？如果rightGenerator的结果为空（没有下一个信号），它的行为就像您希望的那样，但有一个限制，即它立即完成。因此，您需要返回一个可选，或者使用然后返回或开关ifempty。

Answer 3

我有一个类似的问题，我用下面的代码解决了它。我认为不惜一切代价不要迷失在方法链接中是很重要的。因为创建难以阅读的结构非常容易。

@Test
public void mergeMonos(){
    Mono<String> myObject = Mono.just("my object");
    Mono<String> savedToDB = saveToDb(myObject);
    Mono<String> savedToStream = saveToStream(myObject);


    //if you need to wait for the first two to complete
    Flux.concat(savedToDB, savedToStream, myObject)
            .last()
            .subscribe(System.out::println);

    //if you don't need to wait for the db and stream
    Flux.merge(savedToDB, savedToStream, myObject)
            .last()
            .subscribe(System.out::println);
}

private Mono<String> saveToStream(Mono<String> myObject) {
    return myObject.map(t-> "saved to stream");
}

private Mono<String> saveToDb(Mono<String> myObject) {
    return myObject.map(t-> "saved to db");
}