From f9b3840a67c63d4df12f66d671089a25d41f2e01 Mon Sep 17 00:00:00 2001 From: Paul Campbell Date: Tue, 7 May 2019 08:18:08 +0100 Subject: [PATCH] [sync] reformat to enhance ide code folding --- src/main/scala/net/kemitix/s3thorp/Sync.scala | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/main/scala/net/kemitix/s3thorp/Sync.scala b/src/main/scala/net/kemitix/s3thorp/Sync.scala index b2af4f8..c1668d7 100644 --- a/src/main/scala/net/kemitix/s3thorp/Sync.scala +++ b/src/main/scala/net/kemitix/s3thorp/Sync.scala @@ -61,15 +61,13 @@ object Sync { // create blank S3MetaData records (sealed trait?) } yield S3MetaData(path, "", "", Instant.now())) - private def uploadRequiredFilter: S3MetaData => Stream[IO, Path] = - s3Metadata => Stream.eval(for { + private def uploadRequiredFilter: S3MetaData => Stream[IO, Path] = s3Metadata => Stream.eval(for { _ <- putStrLn(s"upload required: ${s3Metadata.localPath}") //md5File(localFile) //filter(localHash => options.force || localHash != metadataHash) } yield s3Metadata.localPath) - private def performUpload: Path => Stream[IO, Promise[Unit]] = - path => Stream.eval(for { + private def performUpload: Path => Stream[IO, Promise[Unit]] = path => Stream.eval(for { _ <- putStrLn(s"upload: $path") // upload p = Promise[Unit]()