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

[sync] reformat to enhance ide code folding

Browse source
This commit is contained in:
Paul Campbell 2019-05-07 08:18:08 +01:00
parent 21b48b1089
commit f9b3840a67
1 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/main/scala/net/kemitix/s3thorp/Sync.scala
View file

@ -61,15 +61,13 @@ object Sync {
// create blank S3MetaData records (sealed trait?) // create blank S3MetaData records (sealed trait?)
} yield S3MetaData(path, "", "", Instant.now())) } yield S3MetaData(path, "", "", Instant.now()))
private def uploadRequiredFilter: S3MetaData => Stream[IO, Path] = private def uploadRequiredFilter: S3MetaData => Stream[IO, Path] = s3Metadata => Stream.eval(for {
s3Metadata => Stream.eval(for {
_ <- putStrLn(s"upload required: ${s3Metadata.localPath}") _ <- putStrLn(s"upload required: ${s3Metadata.localPath}")
//md5File(localFile) //md5File(localFile)
//filter(localHash => options.force || localHash != metadataHash) //filter(localHash => options.force || localHash != metadataHash)
} yield s3Metadata.localPath) } yield s3Metadata.localPath)
private def performUpload: Path => Stream[IO, Promise[Unit]] = private def performUpload: Path => Stream[IO, Promise[Unit]] = path => Stream.eval(for {
path => Stream.eval(for {
_ <- putStrLn(s"upload: $path") _ <- putStrLn(s"upload: $path")
// upload // upload
p = Promise[Unit]() p = Promise[Unit]()