在 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。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）