kemitix/thorp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

[Reactives3client] use S3CatsIOClient

Browse source
This commit is contained in:
Paul Campbell 2019-05-08 10:02:12 +01:00
parent f099765dd3
commit 837ab362c3
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/main/scala/net/kemitix/s3thorp/ReactiveS3Client.scala
View file

@ -1,20 +1,20 @@
package net.kemitix.s3thorp package net.kemitix.s3thorp
import cats.effect.IO
import com.github.j5ik2o.reactive.aws.s3.S3AsyncClient import com.github.j5ik2o.reactive.aws.s3.S3AsyncClient
import com.github.j5ik2o.reactive.aws.s3.cats.S3CatsIOClient
import software.amazon.awssdk.services.s3.model.HeadObjectRequest import software.amazon.awssdk.services.s3.model.HeadObjectRequest
import software.amazon.awssdk.services.s3.{S3AsyncClient => JavaS3AsyncClient} import software.amazon.awssdk.services.s3.{S3AsyncClient => JavaS3AsyncClient}
class ReactiveS3Client extends S3Client { class ReactiveS3Client extends S3Client {
val s3Client = S3AsyncClient(JavaS3AsyncClient.create()) private val s3Client = S3CatsIOClient(S3AsyncClient(JavaS3AsyncClient.create))
override def objectHead(bucket: String, key: String) = { override def objectHead(bucket: String, key: String) = {
IO.fromFuture(IO( val request = HeadObjectRequest.builder()
s3Client.headObject(HeadObjectRequest.builder()
.bucket(bucket) .bucket(bucket)
.key(key) .key(key)
.build()))). .build()
s3Client.headObject(request).
map(r => (r.eTag(), r.lastModified())) map(r => (r.eTag(), r.lastModified()))
} }
} }