final S3ConnectionProperties s3ConnectionProperties = Mock()

    def setup(){
        _ * s3ConnectionProperties.getEndpoint() >> Optional.absent()
        _ * s3ConnectionProperties.getPartSize() >> 512
        _ * s3ConnectionProperties.getMultipartThreshold() >> 1024
    }

    def "Should upload to s3"() {
        given:
        AmazonS3Client amazonS3Client = Mock()

            }
        }
        return Optional.fromNullable(count);
    }

    public Optional<Integer> getMaxErrorRetryCount() {
        return maxErrorRetryCount;
    }

    public long getPartSize() {
        return partSize;
    }

    public long getMultipartThreshold() {
        return partSize * 2;
    }

            InitiateMultipartUploadResult initResponse = amazonS3Client.initiateMultipartUpload(initRequest);
            try {
                long filePosition = 0;
                long partSize = s3ConnectionProperties.getPartSize();

                LOGGER.debug("Attempting to put resource:[{}] into s3 bucket [{}]", s3BucketKey, bucketName);

                for (int partNumber = 1; filePosition < contentLength; partNumber++) {

            getEndpoint() >> Optional.of(server.uri)
            getProxy() >> Optional.fromNullable(null)
            getMaxErrorRetryCount() >> Optional.absent()
            getPartSize() >> 512
            getMultipartThreshold() >> 1024
        }

        S3Client s3Client = new S3Client(authenticationImpl, s3SystemProperties)

        when:
        def stream = new FileInputStream(file)