[s3metadataenricher] rename intermediate function
This commit is contained in:
parent
6af5b8cafc
commit
befd6975fa
1 changed files with 2 additions and 2 deletions
|
@ -9,10 +9,10 @@ import net.kemitix.s3thorp.awssdk.S3Client
|
||||||
trait S3MetaDataEnricher extends S3Client with KeyGenerator {
|
trait S3MetaDataEnricher extends S3Client with KeyGenerator {
|
||||||
|
|
||||||
def enrichWithS3MetaData(c: Config): File => Stream[IO, Either[File, S3MetaData]] = {
|
def enrichWithS3MetaData(c: Config): File => Stream[IO, Either[File, S3MetaData]] = {
|
||||||
val fileToString = generateKey(c)_
|
val remoteKey = generateKey(c)_
|
||||||
file =>
|
file =>
|
||||||
Stream.eval({
|
Stream.eval({
|
||||||
val key = fileToString(file)
|
val key = remoteKey(file)
|
||||||
for {
|
for {
|
||||||
head <- objectHead(c.bucket, key)
|
head <- objectHead(c.bucket, key)
|
||||||
} yield head.map {
|
} yield head.map {
|
||||||
|
|
Loading…
Reference in a new issue