utilizing a stream that does reset operations

Author: Anirav Kareddy

src/test/java/software/amazon/encryption/s3/S3EncryptionClientStreamTest.java

@@ -35,6 +35,7 @@
 import javax.crypto.AEADBadTagException;
 import javax.crypto.KeyGenerator;
 import javax.crypto.SecretKey;
+import java.io.BufferedInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.nio.charset.StandardCharsets;
@@ -342,7 +343,9 @@ public void customSetBufferSizeWithLargeObject() throws IOException {
 
         // Tight bound on the custom buffer size limit of 32MiB
         final long fileSizeExceedingDefaultLimit = 1024 * 1024 * 32 + 1;
-        final InputStream largeObjectStream = new BoundedInputStream(fileSizeExceedingDefaultLimit);
+        final InputStream rawStream = new BoundedInputStream(fileSizeExceedingDefaultLimit);
+        final BufferedInputStream largeObjectStream = new BufferedInputStream(rawStream);
+
         v3ClientWithBuffer32MiB.putObject(PutObjectRequest.builder()
                 .bucket(BUCKET)
                 .key(objectKey)
@@ -361,7 +364,7 @@ public void customSetBufferSizeWithLargeObject() throws IOException {
                 .key(objectKey));
 
 
-        assertTrue(IOUtils.contentEquals(new BoundedInputStream(fileSizeExceedingDefaultLimit), response));
+        assertTrue(IOUtils.contentEquals(new BufferedInputStream(new BoundedInputStream(fileSizeExceedingDefaultLimit)), response));
         response.close();
 
         // Cleanup