Scala 未来类型不匹配问题

Question

我在一个 for yield 场景中遇到了 Scala 和多个期货的问题。 f1 和 f2 都是期货。 f2 future 基于从 f1 future 获得的值。

val result = for {
    f1 <- Await.result(dao.findNode("nodeA"), 5 seconds)            // This returns back a MyNode class
    f2 <- if (f1 != None && f1.isUpAndRunning)
                Future { LookupResult(true, f1.varA, f1.varB) }
          else
                lk ? Lookup(sm.id, sm.("address"))
} yield(f1, f2)

取决于 f1 的结果，当我的 if 语句计算结果为 false 时执行 Lookup()（这需要一些时间并返回 LookupResult），或者我模仿默认的 LookupResult。

返回以下错误：

类型不匹配。必需：Option[B_]，找到：Future[(MyNode, Any)]

我只是没有正确映射结果吗？例如我应该在某处使用 asInstanceOf 吗？无论我做什么我都无法编译它。

非常感谢各位。

Answer 1

您的dao.findNode 方法可能会导致Future[Option[MyNode]]，因此Await.result 使f1 成为Option[MyNode]。不清楚你想要什么类型，但你可以用这个得到Future[(Option[MyNode], LookupResult)]

dao.findNode("nodeA"), 5.seconds)
  .flatMap { nodeOpt: Option[MyNode] =>
    nodeOpt.filter(_.isUpAndRunning)
      .map { node =>
        // node exists and is up and running
        val finalResult = nodeOpt -> LookupResult(true, node.varA, node.varB)

        // it's much more efficient in this scenario to use
        // Future.successful than Future { }
        Future.successful(finalResult)
      }
      .getOrElse {
        // node didn't exist, or wasn't up and running
        val lookupFut = lk ? Lookup(sm.id, sm.("address"))
        lookupFut.map { lookupResult =>
          nodeOpt -> lookupResult
        }
      }
  }

正在发生的事情的大致轮廓是：

• 使用dao查找节点
• 在我们获得（可能不存在的）节点时安排回调以检查它是否已启动并运行（在这种情况下，我们会短路到我们现在已知的最终结果），否则执行查找并构建最终结果，如果查找成功

使用Future.successful 是因为Future {} 几乎肯定会在线程上调度任务并完成未来比构造最终结果产生更多开销。