scala 如何将一种类型的 future 转换为另一种类型的 future

Question

我有一个从数据库中检索数据并返回 Future[ResponseDTO] 类型的函数，然后我需要将它转换为 HttpResponse 的 Future

我的代码:

val responseDTO = database.getResponseDto(service) => Future[ResponseDTO]

responseDTO.onComplete {
   case Success(responseDTO) => HttpResponse(status = responseDTO.responseCode, entity = responseDTO.responsePayload)
   case Failure(exception) => HttpError("error")
}

它不会工作

这个也试过了，还是不行

responseDTO.map(
  dto => EitherT.pure[Future, HttpError](HttpResponse(status = dto.responseCode, entity = dto.responsePayload))
)

Answer 1

使用 transform应该给出你想要的答案:

responseDTO.transform {
  case Success(responseDTO) => Success(HttpResponse(status = responseDTO.responseCode, entity = responseDTO.responsePayload))
  case _ => Success(HttpError("error"))
}

这将返回一个成功的 Future其结果类型与 HttpResponse 兼容和 HttpError .

如果您想保留有关成功/失败的信息，最好使用 Future 的状态来执行此操作。 .在这种情况下，您的代码将使用 transform 的替代版本。 ， 像这样:

case class HttpErrorException(err: HttpError) extends Throwable

responseDTO.transform(
  responseDTO => HttpResponse(status = responseDTO.responseCode, entity = responseDTO.responsePayload),
  _ => HttpErrorException(HttpError("error"))
)

然后您可以使用 Future其余代码中用于提取 HttpResponse 的方法或 HttpErrorException在需要的时候。