This is an automated email from the ASF dual-hosted git repository. ggregory pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/commons-compress.git
commit b1f9359d8f1a7f4fc9425a5fec4e27119851239c Author: Gary Gregory <[email protected]> AuthorDate: Fri Jun 28 16:33:26 2024 -0400 Upgrade commons-io from 2.15.1 to 2.16.1 #513 - Migrate to non-deprecated code - Thanks to madrob Mike Drob and PR 513 - https://github.com/apache/commons-compress/pull/513/files --- .../compressors/snappy/FramedSnappyCompressorInputStream.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStream.java b/src/main/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStream.java index d4bb9e428..3aaaba681 100644 --- a/src/main/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStream.java +++ b/src/main/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStream.java @@ -25,10 +25,10 @@ import java.util.Arrays; import org.apache.commons.codec.digest.PureJavaCrc32C; import org.apache.commons.compress.compressors.CompressorInputStream; -import org.apache.commons.compress.utils.BoundedInputStream; import org.apache.commons.compress.utils.ByteUtils; import org.apache.commons.compress.utils.IOUtils; import org.apache.commons.compress.utils.InputStreamStatistics; +import org.apache.commons.io.input.BoundedInputStream; import org.apache.commons.io.input.CountingInputStream; /** @@ -265,7 +265,14 @@ public class FramedSnappyCompressorInputStream extends CompressorInputStream imp } else { expectedChecksum = -1; } - currentCompressedChunk = new SnappyCompressorInputStream(new BoundedInputStream(inputStream, size), blockSize); + // @formatter:off + currentCompressedChunk = new SnappyCompressorInputStream(BoundedInputStream.builder() + .setInputStream(inputStream) + .setMaxCount(size) + .setPropagateClose(false) + .get(), + blockSize); + // @formatter:on // constructor reads uncompressed size count(currentCompressedChunk.getBytesRead()); } else {
