SpringWebFlux：如何比较两个Mono流的结果并基于过滤器进行保存

Question

情况如下：我有两个MongoDB文档：用户和复制。

在检查用户是否有复制条目（文档）的基础上，我想在MongoDB中添加另一个实体。

目前我正在使用SpringWebFlux和SpringReactiveMongo。请参阅下面的代码。

    @Autowired
    ParserRepository parserRepository;

    @Autowired
    ReproductionRepository reproductionRepository;

    @Autowired
    UserRepository userRepository;

    public void addParser(Parser parser, String keycloakUserId) {

        Mono<User> userMono = userRepository.findByKeycloakUserId(keycloakUserId);
        Mono<Reproduction> reproductionMono = reproductionRepository.findById(parser.getReproductionId());


        userMono.zipWith(reproductionMono)
                .filter(objects -> objects.getT2().getUserId().equals(objects.getT1().get_id()))
                .then(parserRepository.save(parser))
                .switchIfEmpty(Mono.error(new ParserDoesNotBelongToUserException("Unable to add, since this parser does not belong to you")));
        
    }

我的问题如下：如何使用Mono的结果来验证正确的Mono是否存在，并基于该保存解析器文档。基本上结合两个单声道流的结果，以便执行另一个文档的保存，并以非阻塞的方式执行此操作。

上述方法似乎不起作用。在这种情况下，用两个独立的单声道来完成这个场景的最佳方式是什么？欢迎任何最佳实践提示。

Answer 1

摘自Mono#filter文档：

过滤器（谓词）

因此，如果过滤器的计算结果为true，它将通过该值，如果为false，则不会。

问题是您在之后调用然后。单声道的文件

然后（单声道其他）让这个单声道完成，然后播放另一个单声道。

这里的关键词是complete，这基本上意味着，不管前面的行以什么形式完成，只要它完成了，它就会被忽略。因此，不管它在前一行中用（false/true）完成了什么，我们都可以运行，然后运行。

我猜你想要这样的东西：

userMono.zipWith(reproductionMono).flatMap(objects -> {
    if(objects.getT2().getUserId().equals(objects.getT1().get_id()))) {
        return parserRepository.save(parser)
    } else {
        return Mono.error(new ParserDoesNotBelongToUserException("Unable to add, since this parser does not belong to you"));
    }
}