[uploadselectionfilter] update call to uploadRequiredFilter
This commit is contained in:
parent
4c1cf89d51
commit
1abc34f30b
1 changed files with 2 additions and 1 deletions
|
@ -11,8 +11,9 @@ class UploadSelectionFilterSuite extends FunSpec {
|
||||||
describe("uploadRequiredFilter") {
|
describe("uploadRequiredFilter") {
|
||||||
val localFile = new File("src/test/scala/net/kemitix/s3thorp/test-file-for-hash.txt")
|
val localFile = new File("src/test/scala/net/kemitix/s3thorp/test-file-for-hash.txt")
|
||||||
val localHash = "0cbfe978783bd7950d5da4ff85e4af37"
|
val localHash = "0cbfe978783bd7950d5da4ff85e4af37"
|
||||||
|
val config = Config("bucket", "prefix", localFile.getParentFile)
|
||||||
def invokeSubject(input: Either[File, S3MetaData]) =
|
def invokeSubject(input: Either[File, S3MetaData]) =
|
||||||
uploadRequiredFilter(input).compile.toList.unsafeRunSync()
|
uploadRequiredFilter(config)(input).compile.toList.unsafeRunSync()
|
||||||
describe("when supplied a file") {
|
describe("when supplied a file") {
|
||||||
val input = Left(localFile)
|
val input = Left(localFile)
|
||||||
it("should be marked for upload") {
|
it("should be marked for upload") {
|
||||||
|
|
Loading…
Reference in a new issue