当hasElement时，如何分支Mono以使主进程位于空进程和类似错误的进程上？

Question

我试图理解反应性范式，但逻辑似乎与我的需求背道而驰。

这种情况是注册过程的早期阶段：从注册数据开始，检查提供的电子邮件是否存在帐户（将帐户返回到或null）并从那里进行处理。使用命令式方法，这很容易；账户上的分支==null。但对于反应型范式，我无法理解。

如果我正在处理帐户，并用中的某个内容替换null，那就好了。但在这个例子中，它实际上是颠倒的：当我返回null时，即没有帐户存在，我想进行主要处理以创建帐户，而当它不是null时，我想使用错误等价的回退。

我发现唯一可行的方法是首先使用命令分支来包装反应元素，根据：

public ResponseDto registerAccount (RegistrationDto data)
  ResponseDto responseDto = new ResponseDto ();
  if (accountExists(data.getEmail()) {
    // return responseDto with account-exists error messaging
  } else {
    // create the account, send verification email, etc
    // return responseDto with information that verification is sent
  }
}

public boolean accountExists (String email) {
  return retrieveAccount(email)
      .hasElement().block(); 
}

public Mono<AccountDto> retrieveAccount (String email) {
  // calls db service; returns either the Mono-wrapped AccountDto or Mono-wrapped null.
}

考虑到我正被推下被动路径，我宁愿避免这种混合方法。

如果处理的主体取决于单声道为空，而错误状态的等价物是当它有要处理的内容时，我该如何处理结果？




Answer 1

您离反应路径只有一步之遥：

public Mono<ResponseDto> registerAccount(RegistrationDto data) {
    return retrieveAccount(data.getEmail())
        .hasElement()
        .flatMap(accountExists -> {
            if (accountExists) {
                // return responseDto with account-exists error messaging
            } else {
                return createAccount(data);
            }
        });
}

public Mono<AccountDto> retrieveAccount(String email) {
    // calls db service; returns either the Mono-wrapped AccountDto or Mono-wrapped null.
}

private Mono<ResponseDto> createAccount(RegistrationDto data) {
    // create the account, send verification email, etc
    // return responseDto with information that verification is sent
}