Scala 未来的理解

Question

我有一个方法应该遍历 Future 并返回一个 Tuple。这里是：

  private def myMethod(id: Long): Future[(Double, Double)] = {
    val result = for {
      someValue <- run { getFromDb(id).headOption }
      value     <- someValue
    } yield {
      value.valueType match {
        case ValueType.TypeA => (1.0, 1.0)
        case ValueType.TypeB => (2.0, 2.0)
      }
    }
  }

这是我的运行方法：

  private def run[R](dbio: slick.dbio.DBIOAction[R, slick.dbio.NoStream, scala.Nothing]) = async {
    await(db.run(dbio))
  }

它使用 Scala Async 库来计时我对数据库的调用！

getFromDB 方法只是做一个查询：

def getFromDb(myId: Long) {
  MyTableQuery.filter(_.id === myId)
}

它抱怨 myMethod 返回一个 Future[Nothing]。我在这里看不到任何问题。关于什么可能不满足我正在寻找的返回类型的任何线索？

Answer 1

这是一个显示相同错误的简化版本：

def method: Future[(Double, Double)] = {
  val result = for {
    someValue <- Future("a")
    value     <- Future("b")
  } yield {
    value match {
      case "a" => (1.0, 1.0)
      case "b" => (2.0, 2.0)
    }
  }
}

问题是您在result 值中捕获返回类型，因此该方法没有返回类型。此简化函数的有效形式为以下任一形式：

def method: Future[(Double, Double)] = {
  val result = for {
    someValue <- Future("a")
    value     <- Future("b")
  } yield {
    value match {
      case "a" => (1.0, 1.0)
      case "b" => (2.0, 2.0)
    }
  }
  result
}

或者：

def method: Future[(Double, Double)] = {
  for {
    someValue <- Future("a")
    value     <- Future("b")
  } yield {
    value match {
      case "a" => (1.0, 1.0)
      case "b" => (2.0, 2.0)
    }
  }
}