在 scala.concurrent.Future 中包含 .futureValue 方法？

如何解决在 scala.concurrent.Future 中包含 .futureValue 方法？

我正在学习通过 this tutorial（完整测试代码 can be found here）从 S3 存储桶获取数据的教程。

当我使用代码时

val s3names: Source[Option[(Source[ByteString,NotUsed],ObjectMetadata)],NotUsed] =
S3.download(bucket,bucketKey)
val Some((data: Source[ByteString,_],Metadata)) = s3names.runWith(Sink.head).futureValue

我明白

[error] ...../src/main/scala/streams/package.scala:33:82: value futureValue is not a member of scala.concurrent.Future[Option[(akka.stream.scaladsl.source[akka.util.ByteString,akka.NotUsed],akka.stream.alpakka.s3.ObjectMetadata)]]
[error]   val Some((data: Source[ByteString,Metadata)) = s3names.runWith(Sink.head).futureValue

经过过多的探索，我发现在scalatest包的ScalaFutures类中存在一个futureValue方法，但在相关测试代码的导入中没有看到ScalaFutures（其他地方可以找到）。

虽然我最终可能对使用 Alpakka S3 的细节有疑问，但我真的很困惑这个 .futureValue 方法的来源以及为什么它在 Alpakka 测试包中显然有效。

使用 Akka 2.6.12、akka-stream-alpakka-s3 2.0.2 和 Scala 2.13.4。