如何连接两个Scala期货

发布时间：2020-12-16 10:07:10 所属栏目：安全来源：网络整理

导读：我有两个Future函数： def parseIntFuture(str: String) = Future{scala.util.Try(str.toInt).toOption}def divideFuture(a: Int,b: Int) = Future{ if (b == 0) None else Some(a / b)} 现在我想连接它们并最终获得Future [Option [Int]]类型结果,这是第二

我有两个Future函数：

def parseIntFuture(str: String) = Future{scala.util.Try(str.toInt).toOption}
def divideFuture(a: Int,b: Int) = Future{ if (b == 0) None else Some(a / b)}

现在我想连接它们并最终获得Future [Option [Int]]类型结果,这是第二个返回值,但如果我这样做：

def stringDivideBy(aStr: String,bStr: String) = {
    val x = for {
        aNum <- parseIntFuture(aStr)
        bNum <- parseIntFuture(bStr)
    } yield (aNum,bNum)

    x.map(n => {
        for{
            a <- n._1
            b <- n._2
        } yield divideFuture(a,b)
    })
}

实际上我只会获得Future [Option [Future [Option [Int]]]]而不是Future [Option [Int]].我知道这是因为我将一个Future传递给另一个,但我不知道连接这两个Futures的正确方法是一个接一个避免使用Await.我停止明确使用Await,那么解决方案是什么？

解决方法

有一个叫做 OptionT monad transformer的东西可以解决这个问题.使用OptionT,您的代码看起来有点像

import cats.data.OptionT

// ...

val x = (for {
    aNum <- OptionT(parseIntFuture(aStr))
    bNum <- OptionT(parseIntFuture(bStr))
    res <- OptionT(divideFuture(aNum,bNum))
} yield res).value

并返回Future [Option [Int]].

您可以以嵌套for-comprehensions为代价来避免monad变换器：

import scala.concurrent._
import scala.concurrent.ExecutionContext.Implicits.global

def parseIntFuture(str: String) = Future{scala.util.Try(str.toInt).toOption}
def divideFuture(a: Int,b: Int) = Future{ if (b == 0) None else Some(a / b)}

def stringDivideBy(aStr: String,bStr: String): Future[Option[Int]] = {
  for {
    aOpt <- parseIntFuture(aStr)
    bOpt <- parseIntFuture(bStr)
    resOpt <- 
      (for {
        a <- aOpt
        b <- bOpt
      } yield divideFuture(a,b))
      .getOrElse(Future { None })
  } yield resOpt
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!