小编cga*_*ill的帖子

我正在尝试将项目转换为使用 Spring WebFlux，但在使一些基本业务逻辑正常工作时遇到了问题。我有一个负责检索/持久化记录的存储库层和一个负责应用程序业务规则的服务层。我想要做的（在服务中）层是检查给定用户名的用户是否已经存在。如果是这样，我想回复一个错误。如果没有，我想允许插入发生。

我在存储库层调用一个方法，该方法将通过用户名查找用户，如果找不到，它将返回一个空的 Mono。这按预期工作；但是，我尝试了 flatMap 和（defaultIfEmpty 和 swithIfEmpty）的各种组合，但无法编译/构建。

    public Mono<User> insertUser(User user) {
        return userRepository.findByUsername(user.username())
            .flatMap(__ -> Mono.error(new DuplicateResourceException("User already exists with username [" + user.username() + "]")))
            .switchIfEmpty(userRepository.insertUser(user));
    }

我得到的错误是Mono<Object> cannot be converted to Mono<User>，所以swithIfEmpty似乎没有反映适当的类型，并且转换似乎也不起作用。