问题描述
我需要使用 Scala 通过 Alpakka 从 S3 流式传输文件。 Wenn 创建了一个流,数据不断地重新传输,而不是给我一个确定的未来。这是我的代码:
val bucket = "my-bucket"
val prefix = "somePrefix"
val duration = 20.seconds
implicit val system: ActorSystem = ActorSystem("test-aws")
implicit val materializer: Materializer = Materializer(system)
val resultFut: Future[Seq[ListBucketResultContents]] =
S3.listBucket(bucket,Some(prefix))
.runWith(Sink.seq)
val result = Await.result(resultFut,duration)
println(s"\n\nRESULT: ${result.toString()}\n\n")
永远不会到达等待,并且在接收器之前打印值时,一切都会像
一样重复item1 => item2 => item3 => item1 => item2 => item3 ...
有人知道我做错了什么吗?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)