情况如下：我有两个mongodb文档：用户和复制。
在检查用户是否有复制条目（文档）的基础上，我想在mongodb中添加另一个实体。
目前我正在使用SpringWebFlux和SpringMongo。请参阅下面的代码。

@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，并基于save解析器文档。基本上结合两个mono流的结果来执行另一个文档的保存，并以非阻塞的方式执行。
上述方法显然不起作用。在这种情况下，用两个单独的单声道来做这个场景的最佳方法是什么？欢迎提供任何最佳实践提示。