Scala 未来类型不匹配问题

Question

我遇到了一个关于Scala和多种未来收益的问题。f1和f2都是期货。f2期货基于从f1期货获得的值。

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。

返回以下错误：

类型不匹配。必需:选项[B_]，找到:Future[(MyNode，Any)]

我只是没有正确映射结果吗？例如，我应该在某个地方使用asInstanceOf，因为无论我做什么，我都无法对其进行编译。

非常感谢各位。

Answer 1

您的 dao.findNode 方法很有可能导致 Future[Option[MyNode]]，因此 Await.result 使 f1 成为 Option[MyNode]。目前还不清楚你想要什么类型，但你可以用这个得到一个未来[（选项[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
        }
      }
  }

大致的情况是:

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

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