扁平化未来[EitherT[Future, A, B]]

Question

如标题所述。

使用EitherT[Future, A, B] 完成了许多操作。有时我想通过另一个具有签名A => Future[C] 的操作向左或向右映射。其他情况是EitherT[Future, A, B] 是对未来结果Future[EitherT[Future, A, B]] 的映射结果。

我怎样才能优雅地展平类型：

EitherT[Future, Future[A], Future[B]] 和 Future[EitherT[Future, A, B]]

提前谢谢你。

Answer 1

在所有情况下，您都可以使用EitherT#flatMap（或EitherT#flatMapF），同时将一些值提升到EitherT（或与flatMapF 分离（\/）。

• 将B => F[C] 映射到EitherT[F, A, B]：

  flatMap + 提升

  import scala.concurrent.Future
  import scala.concurrent.ExecutionContext.Implicits.global
  
  import scalaz._, Scalaz._
  
  def f(i: Int): Future[Double] = Future.successful(i.toDouble)
  val r = EitherT.right[Future, String, Int](Future.successful(1))
  
  r.flatMap(i => EitherT.right(f(i)))
  // or
  r.flatMapF(i => f(i).map(_.right))
  

• 将A => F[C] 映射到EitherT[F, A, B]：

  swap + flatMap + 电梯

  def g(s: String): Future[Int] = Future.successful(s.length)
  
  val l = EitherT.left[Future, String, Int](Future.successful("error"))
  
  l.swap.flatMap(s => EitherT.right(g(s))).swap
  // or
  l.swap.flatMap(s => EitherT.left[Future, Int, Int](g(s)))
  // or
  l.swap.flatMapF(s => g(s).map(_.left))
  

• 将A => Either[F, B, C] 映射到F[A]：

  电梯+flatMap

  def h(i: Int): EitherT[Future, String, Int] = 
    EitherT.right(Future.successful(i + 1))
  
  val fut = Future.successful(1)
  
  // mapping gives us Future[EitherT[Future, String, Int]]
  fut.map(h)                    
  
  // lifting to EitherT and flatMap gives us EitherT[Future, String, Int]
  EitherT.right(fut).flatMap(h)