2

我有以下代码


def processInfoAndReturnResponse(input: Input]): EitherT[Future, CustomException, A] = ???

def sendMessage(message: A): monix.eval.Task[Boolean] = ???

def anotherMethod(message: Input): Future[Either[CustomException, Unit]]= ???
def integrate(): Future[Either[GoogleException, A]] = {
(for {
  response <- processInfoAndModelResponse(input)
  _ <- EitherT.liftF[Future, CustomException, A](sendMessage(response).map(_ => response).runToFuture
}yield response).value

到目前为止，这一切都很好。但是现在，我想从 sendMessage 中获取布尔值，然后只有当 sendMessage 返回 true 时，我才想调用另一个方法。

我知道它们是不同的单子。请让我知道如何以更简洁的方式添加所有三个调用以进行理解。感谢帮助

4

1 回答 1

3

不幸的是， EitherT 和 Task 是不同的 monad，而且 monad 不能组合，所以你不能直接在同一个地方使用它们来理解。

您可以做的是将 Task 提升到 EitherT 但在这种情况下， EitherT 的类型参数 F 必须是 Task，在您的情况下是 Future。

所以你必须做两件事：

  1. 将任务转化为未来
  2. 将未来提升到 EitherT

假设您的另一种方法如下所示：

def anotherMethod(input: Integer): EitherT[Future, Exception, Unit] = EitherT.rightT[Future, Exception](())

所以你的理解可能是这样的：

import cats.implicits._
import scala.concurrent.ExecutionContext.Implicits._

val prog = for {
    //you need to use leftWiden adjust left of either to common type
    response <- processInfoAndReturnResponse(inp).leftWiden[Exception]
    //running task to Future and then lifting to EitherT
    i <- EitherT.liftF[Future, Exception, Integer](sendMessage(response).runToFuture)
    _ <- anotherMethod(i)
} yield ()

//prog is of type EitherT so we have to unwrap it to regular Future with rethrowT
val future: Future[Unit] = prog.rethrowT

要在编辑后回答您的问题，您可以whenA在理解中使用有条件地使用效果：

def integrate(): Future[Either[GoogleException, A]] ={
  (for {
    response <- processInfoAndModelResponse(input)
    sendStatus <- EitherT.liftF[Future, CustomException, Boolean](sendMessage(response).runToFuture)
    finalresult <- anotherMethod(input).whenA(sendStatus)
  } yield finalresult).value
}
于 2020-09-25T20:28:34.950 回答