Scala alpakka 不断在 listBucket 上重新流式传输存储桶元数据

如何解决Scala alpakka 不断在 listBucket 上重新流式传输存储桶元数据

我需要使用 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 ...

有人知道我做错了什么吗？