无法使akka streams/alpakka S3在简单情况下工作

Question

我正在做一件我认为非常简单的事情来检查alpakka是否在工作：

val awsCreds = AwsBasicCredentials.create("xxx", "xxx")
val credentialsProvider = StaticCredentialsProvider.create(awsCreds)
implicit val staticCreds = S3Attributes.settings(S3Ext(context.system).settings.withCredentialsProvider(credentialsProvider)
  .withS3RegionProvider(new AwsRegionProvider {val getRegion: Region = Region.US_EAST_2}))

val d = S3.checkIfBucketExists(action.bucket)
d foreach { msg => log.info("mgs: " + msg.toString)}

 msgs: NotExists

Answer 1

只是我的粗心。..

一个错误的拷贝为混合添加了一个额外的隐式系统。在Akka2.6中对隐式物质化器做了一些改动，我认为这些改动，加上额外的隐式actor系统，形成了一个奇怪的混合体。