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 f2d3fa8343916153e2b8da988a84106967c96247
Author: Gary Gregory <[email protected]>
AuthorDate: Fri Jun 28 16:32:08 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/lz4/FramedLZ4CompressorInputStream.java        | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git 
a/src/main/java/org/apache/commons/compress/compressors/lz4/FramedLZ4CompressorInputStream.java
 
b/src/main/java/org/apache/commons/compress/compressors/lz4/FramedLZ4CompressorInputStream.java
index 3c3a41a34..a05c48ac9 100644
--- 
a/src/main/java/org/apache/commons/compress/compressors/lz4/FramedLZ4CompressorInputStream.java
+++ 
b/src/main/java/org/apache/commons/compress/compressors/lz4/FramedLZ4CompressorInputStream.java
@@ -24,10 +24,10 @@ import java.util.Arrays;
 import java.util.zip.CheckedInputStream;
 
 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;
 
 /**
@@ -207,7 +207,13 @@ public class FramedLZ4CompressorInputStream extends 
CompressorInputStream implem
             }
             return;
         }
-        InputStream capped = new BoundedInputStream(inputStream, realLen);
+        // @formatter:off
+        InputStream capped = BoundedInputStream.builder()
+                .setInputStream(inputStream)
+                .setMaxCount(realLen)
+                .setPropagateClose(false)
+                .get();
+        // @formatter:on
         if (expectBlockChecksum) {
             capped = new CheckedInputStream(capped, blockHash);
         }

Reply via email to