Skip to content

Instantly share code, notes, and snippets.

@yomajkel yomajkel/post.scala
Created Sep 24, 2018

Embed
What would you like to do?
the description for this gist
class S3AlpakkaService()(implicit as: ActorSystem, m: Materializer) extends S3Conf {
private val s3Client: S3Client = S3Client(credentialsProvider, region)
def sink(fileInfo: FileInfo): Sink[ByteString, Future[MultipartUploadResult]] = {
val fileName = UUID.randomUUID().toString + ".tmp"
val key = s"alpakka/${fileName}"
s3Client.multipartUpload(bucketName, key)
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.