diff --git a/src/test/scala/net/kemitix/s3thorp/UploadSelectionFilterSuite.scala b/src/test/scala/net/kemitix/s3thorp/UploadSelectionFilterSuite.scala index 184cb35..0432226 100644 --- a/src/test/scala/net/kemitix/s3thorp/UploadSelectionFilterSuite.scala +++ b/src/test/scala/net/kemitix/s3thorp/UploadSelectionFilterSuite.scala @@ -11,9 +11,8 @@ class UploadSelectionFilterSuite extends FunSpec { describe("uploadRequiredFilter") { val localFile = new File("src/test/scala/net/kemitix/s3thorp/test-file-for-hash.txt") val localHash = "0cbfe978783bd7950d5da4ff85e4af37" - def invokeSubject(input: Either[File, S3MetaData]) = { + def invokeSubject(input: Either[File, S3MetaData]) = uploadRequiredFilter(input).compile.toList.unsafeRunSync() - } describe("when supplied a file") { val input = Left(localFile) it("should be marked for upload") {