将三个操作与WebFlux相结合

Question

我不明白如何结合三个相互依赖的操作。

我有新用户需要保存到基地：

>

从基础获取项目。

  roleRepo.findByName("USER"); // return Mono<Role>

  user.setRole(...); // set result from roleRepo.findByName("USER") is String

将第一次操作的数据保存到数据库中

      userRepo.save(user); // return Mono<User>

保存到基本的新用户角色

      UserRole uRole = new UserRole();
      urole.setUserId(user.getId); 
      urole.setRoleId(role.Id);  
      userRolesRepo.save(uRole) // return Mono<UserRole>

最后，方法返回

 Mono<User>

到控制器。

Answer 1

通过使用平面图合并异步操作。尽量像锁链一样使用它们，避免嵌套。

没有测试，但这应该给你一个开端：

java prettyprint-override">roleRepo.findByName("USER")
        .flatMap(role -> {
            user.setRole(role);
            return Mono.just(user);
        })
        .flatMap(user -> userRepo.save(user))
        .flatMap(user -> {
            UserRole uRole = new UserRole();
            urole.setUserId(user.getId); 
            urole.setRoleId(role.Id);
            return Mono.zip(Mono.just(user), userRolesRepo.save(uRole));
        })
        .flatMap(data -> Mono.just(data.getT1()));