From df0df4962492c141364fc6d5425089ee54d4201e Mon Sep 17 00:00:00 2001 From: Paul Campbell Date: Thu, 9 May 2019 08:29:18 +0100 Subject: [PATCH] [s3metadataenricher] remove putStrLn --- .../kemitix/s3thorp/S3MetaDataEnricher.scala | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala b/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala index 976da82..6b9d0da 100644 --- a/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala +++ b/src/main/scala/net/kemitix/s3thorp/S3MetaDataEnricher.scala @@ -4,7 +4,6 @@ import java.io.File import fs2.Stream import cats.effect.IO -import Main.putStrLn trait S3MetaDataEnricher extends S3Client { @@ -15,13 +14,14 @@ trait S3MetaDataEnricher extends S3Client { def enrichWithS3MetaData(c: Config): File => Stream[IO, Either[File, S3MetaData]] = { val fileToString = generateKey(c)_ file => - Stream.eval(for { - _ <- putStrLn(s"enrich: $file") - key = fileToString(file) - head <- objectHead(c.bucket, key) - } yield head.map { - case (hash,lastModified) => - Right(S3MetaData(file, key, hash, lastModified)) - }.getOrElse(Left(file))) + Stream.eval({ + val key = fileToString(file) + for { + head <- objectHead(c.bucket, key) + } yield head.map { + case (hash,lastModified) => + Right(S3MetaData(file, key, hash, lastModified)) + }.getOrElse(Left(file)) + }) } }