如何将 Future[Option[(Person, Future[Vector[Order]])]] 转换为 Future[Option[(Person, Vector[Order])]]

Question

我目前有这个：

def maybePerson(id: Int): Future[Option[Person]] = ???
def orders(personId : Int): Future[Vector[Order]] = ???

val maybePersonAndOrders: Future[Option[(Person, Future[Vector[Order]])]] =
  maybePerson(is = 10).map(_.map { person =>
    (person, orders(person.id))
  })

如何将其转化为（将两个futurs合二为一）：

val maybePersonAndOrders: Future[Option[(Person, Vector[Order])]] = ???

Answer 1

考虑OptionT monad 转换器

(for {
  person <- OptionT(maybePerson(42))
  orders <- OptionT.liftF(orders(person.id))
} yield {
  (person, orders)
}).value

这是一个工作示例

import cats.data.OptionT
import cats.implicits._
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future

object OptionTExample extends App {

  case class Person(id: Int, name: String)
  case class Order(personId: Int)

  def maybePerson(id: Int): Future[Option[Person]] = Future(Some(Person(42, "picard")))
  def orders(personId : Int): Future[Vector[Order]] = Future(Vector(Order(personId)))

  val maybePersonAndOrders: Future[Option[(Person, Vector[Order])]] = {
    (for {
      person <- OptionT(maybePerson(42))
      orders <- OptionT.liftF(orders(person.id))
    } yield {
      (person, orders)
    }).value
  }

  maybePersonAndOrders.map(println)
  Thread.sleep(1000)
}

哪个输出

Some((Person(42,picard),Vector(Order(42))))