斯卡拉: "required: scala.concurrent.Future[?]"

Question

编辑

仍然没有找到解决方案，所以我最终创建了两个 someFuture 方法。一个返回 future ，一个不返回(让 otherFuture 编译)

---

我正在尝试返回 Future[Option[JsObject]] 但一直出现此错误:

required: scala.concurrent.Future[?]

我在做什么

def someFuture:Future[Option[JsObject]] =
  Future {
    Option(JsObject())
  }

def otherFuture:Future[Option[JsObject]] =
  Future {
    Option(JsObject(
      someFuture.flatMap(_.get)
    ))
  }

// get error here
found   : JsObject
[error]  required: scala.concurrent.Future[?]

如何在不出错的情况下返回 JsObject？

Answer 1

问题是 someFuture.flatMap(_.get) 无法编译——你需要提供一个接受 JsObject 并返回 的函数Future[Whatever] 在 someFuture 上使用 flatMap。

你可能想要这样的东西:

def otherFuture: Future[Option[JsObject]] = someFuture.map { opt =>
  Option(JsObject(opt.get))
}

不过，如果您只是像这样调用 .get 的话，实际上没有任何理由使用 Option，所以以下可能更好:

def otherFuture: Future[Option[JsObject]] = someFuture.map(_.map(JsObject(_)))

现在如果 future 满足一个非空选项，选项的内容将被包裹在另一层JsObject中，这似乎是你的目标？

请注意，如果您使用 Option 来表示失败，您可能需要考虑内置于 Future 中的失败处理。