You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@commons.apache.org by gg...@apache.org on 2020/11/21 15:26:15 UTC
[commons-compress] branch master updated: Use try-with-resource.
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
The following commit(s) were added to refs/heads/master by this push:
new d959766 Use try-with-resource.
d959766 is described below
commit d959766c1419a677f1583b31f654387a735e5589
Author: Gary Gregory <ga...@gmail.com>
AuthorDate: Sat Nov 21 10:26:10 2020 -0500
Use try-with-resource.
---
.../bzip2/BZip2CompressorOutputStream.java | 5 +----
.../commons/compress/archivers/SevenZTestCase.java | 8 +------
.../compress/archivers/tar/SparseFilesTest.java | 16 ++-----------
.../archivers/tar/TarArchiveInputStreamTest.java | 16 ++-----------
.../archivers/zip/EncryptedArchiveTest.java | 8 +------
.../commons/compress/archivers/zip/Lister.java | 8 +------
.../compress/archivers/zip/UTF8ZipFilesTest.java | 16 ++-----------
.../compress/archivers/zip/Zip64SupportIT.java | 22 ++++--------------
.../archivers/zip/ZipArchiveInputStreamTest.java | 26 ++++------------------
.../compress/compressors/DeflateTestCase.java | 25 +++++----------------
.../compress/compressors/FramedSnappyTestCase.java | 11 ++-------
.../commons/compress/compressors/GZipTestCase.java | 11 ++-------
.../commons/compress/compressors/LZMATestCase.java | 7 +-----
.../commons/compress/compressors/XZTestCase.java | 11 ++-------
.../commons/compress/compressors/ZTestCase.java | 11 ++-------
.../brotli/BrotliCompressorInputStreamTest.java | 11 ++-------
.../FramedSnappyCompressorInputStreamTest.java | 11 ++-------
.../zstandard/ZstdCompressorInputStreamTest.java | 11 ++-------
18 files changed, 39 insertions(+), 195 deletions(-)
diff --git a/src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java b/src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java
index f92bb5f..a104b35 100644
--- a/src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java
+++ b/src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java
@@ -501,11 +501,8 @@ public class BZip2CompressorOutputStream extends CompressorOutputStream
@Override
public void close() throws IOException {
if (!closed) {
- final OutputStream outShadow = this.out;
- try {
+ try (OutputStream outShadow = this.out) {
finish();
- } finally {
- outShadow.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/SevenZTestCase.java b/src/test/java/org/apache/commons/compress/archivers/SevenZTestCase.java
index dd74e92..fc2a7b5 100644
--- a/src/test/java/org/apache/commons/compress/archivers/SevenZTestCase.java
+++ b/src/test/java/org/apache/commons/compress/archivers/SevenZTestCase.java
@@ -206,18 +206,12 @@ public class SevenZTestCase extends AbstractTestCase {
}
private void copy(final File src, final SevenZOutputFile dst) throws IOException {
- FileInputStream fis = null;
- try {
- fis = new FileInputStream(src);
+ try (FileInputStream fis = new FileInputStream(src)) {
final byte[] buffer = new byte[8*1024];
int bytesRead;
while ((bytesRead = fis.read(buffer)) >= 0) {
dst.write(buffer, 0, bytesRead);
}
- } finally {
- if (fis != null) {
- fis.close();
- }
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/tar/SparseFilesTest.java b/src/test/java/org/apache/commons/compress/archivers/tar/SparseFilesTest.java
index 336df29..d528b65 100644
--- a/src/test/java/org/apache/commons/compress/archivers/tar/SparseFilesTest.java
+++ b/src/test/java/org/apache/commons/compress/archivers/tar/SparseFilesTest.java
@@ -39,9 +39,7 @@ public class SparseFilesTest extends AbstractTestCase {
@Test
public void testOldGNU() throws Throwable {
final File file = getFile("oldgnu_sparse.tar");
- TarArchiveInputStream tin = null;
- try {
- tin = new TarArchiveInputStream(new FileInputStream(file));
+ try (TarArchiveInputStream tin = new TarArchiveInputStream(new FileInputStream(file))) {
final TarArchiveEntry ae = tin.getNextTarEntry();
assertEquals("sparsefile", ae.getName());
assertTrue(ae.isOldGNUSparse());
@@ -60,26 +58,16 @@ public class SparseFilesTest extends AbstractTestCase {
assertEquals(3101184L, sparseHeaders.get(2).getOffset());
assertEquals(0, sparseHeaders.get(2).getNumbytes());
- } finally {
- if (tin != null) {
- tin.close();
- }
}
}
@Test
public void testPaxGNU() throws Throwable {
final File file = getFile("pax_gnu_sparse.tar");
- TarArchiveInputStream tin = null;
- try {
- tin = new TarArchiveInputStream(new FileInputStream(file));
+ try (TarArchiveInputStream tin = new TarArchiveInputStream(new FileInputStream(file))) {
assertPaxGNUEntry(tin, "0.0");
assertPaxGNUEntry(tin, "0.1");
assertPaxGNUEntry(tin, "1.0");
- } finally {
- if (tin != null) {
- tin.close();
- }
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/tar/TarArchiveInputStreamTest.java b/src/test/java/org/apache/commons/compress/archivers/tar/TarArchiveInputStreamTest.java
index d629975..3acf8fb 100644
--- a/src/test/java/org/apache/commons/compress/archivers/tar/TarArchiveInputStreamTest.java
+++ b/src/test/java/org/apache/commons/compress/archivers/tar/TarArchiveInputStreamTest.java
@@ -113,19 +113,13 @@ public class TarArchiveInputStreamTest extends AbstractTestCase {
@Test
public void workaroundForBrokenTimeHeader() throws Exception {
- TarArchiveInputStream in = null;
- try {
- in = new TarArchiveInputStream(new FileInputStream(getFile("simple-aix-native-tar.tar")));
+ try (TarArchiveInputStream in = new TarArchiveInputStream(new FileInputStream(getFile("simple-aix-native-tar.tar")))) {
TarArchiveEntry tae = in.getNextTarEntry();
tae = in.getNextTarEntry();
assertEquals("sample/link-to-txt-file.lnk", tae.getName());
assertEquals(new Date(0), tae.getLastModifiedDate());
assertTrue(tae.isSymbolicLink());
assertTrue(tae.isCheckSumOK());
- } finally {
- if (in != null) {
- in.close();
- }
}
}
@@ -141,9 +135,7 @@ public class TarArchiveInputStreamTest extends AbstractTestCase {
}
private void datePriorToEpoch(final String archive) throws Exception {
- TarArchiveInputStream in = null;
- try {
- in = new TarArchiveInputStream(new FileInputStream(getFile(archive)));
+ try (TarArchiveInputStream in = new TarArchiveInputStream(new FileInputStream(getFile(archive)))) {
final TarArchiveEntry tae = in.getNextTarEntry();
assertEquals("foo", tae.getName());
final Calendar cal = Calendar.getInstance(TimeZone.getTimeZone("GMT"));
@@ -151,10 +143,6 @@ public class TarArchiveInputStreamTest extends AbstractTestCase {
cal.set(Calendar.MILLISECOND, 0);
assertEquals(cal.getTime(), tae.getLastModifiedDate());
assertTrue(tae.isCheckSumOK());
- } finally {
- if (in != null) {
- in.close();
- }
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/zip/EncryptedArchiveTest.java b/src/test/java/org/apache/commons/compress/archivers/zip/EncryptedArchiveTest.java
index 8c04c52..d2e749a 100644
--- a/src/test/java/org/apache/commons/compress/archivers/zip/EncryptedArchiveTest.java
+++ b/src/test/java/org/apache/commons/compress/archivers/zip/EncryptedArchiveTest.java
@@ -56,9 +56,7 @@ public class EncryptedArchiveTest {
public void testReadPasswordEncryptedEntryViaStream()
throws IOException {
final File file = getFile("password-encrypted.zip");
- ZipArchiveInputStream zin = null;
- try {
- zin = new ZipArchiveInputStream(new FileInputStream(file));
+ try (ZipArchiveInputStream zin = new ZipArchiveInputStream(new FileInputStream(file))) {
final ZipArchiveEntry zae = zin.getNextZipEntry();
assertEquals("LICENSE.txt", zae.getName());
assertTrue(zae.getGeneralPurposeBit().usesEncryption());
@@ -72,10 +70,6 @@ public class EncryptedArchiveTest {
assertSame(UnsupportedZipFeatureException.Feature.ENCRYPTION,
ex.getFeature());
}
- } finally {
- if (zin != null) {
- zin.close();
- }
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/zip/Lister.java b/src/test/java/org/apache/commons/compress/archivers/zip/Lister.java
index a633715..19f8e5d 100644
--- a/src/test/java/org/apache/commons/compress/archivers/zip/Lister.java
+++ b/src/test/java/org/apache/commons/compress/archivers/zip/Lister.java
@@ -94,14 +94,8 @@ public final class Lister {
if (!f.getParentFile().exists()) {
f.getParentFile().mkdirs();
}
- FileOutputStream fos = null;
- try {
- fos = new FileOutputStream(f);
+ try (FileOutputStream fos = new FileOutputStream(f)) {
IOUtils.copy(is, fos);
- } finally {
- if (fos != null) {
- fos.close();
- }
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/zip/UTF8ZipFilesTest.java b/src/test/java/org/apache/commons/compress/archivers/zip/UTF8ZipFilesTest.java
index 7c0b88b..7731a1e 100644
--- a/src/test/java/org/apache/commons/compress/archivers/zip/UTF8ZipFilesTest.java
+++ b/src/test/java/org/apache/commons/compress/archivers/zip/UTF8ZipFilesTest.java
@@ -114,16 +114,10 @@ public class UTF8ZipFilesTest extends AbstractTestCase {
public void testRead7ZipArchiveForStream() throws IOException {
final FileInputStream archive =
new FileInputStream(getFile("utf8-7zip-test.zip"));
- ZipArchiveInputStream zi = null;
- try {
- zi = new ZipArchiveInputStream(archive, CP437, false);
+ try (ZipArchiveInputStream zi = new ZipArchiveInputStream(archive, CP437, false)) {
assertEquals(ASCII_TXT, zi.getNextEntry().getName());
assertEquals(OIL_BARREL_TXT, zi.getNextEntry().getName());
assertEquals(EURO_FOR_DOLLAR_TXT, zi.getNextEntry().getName());
- } finally {
- if (zi != null) {
- zi.close();
- }
}
}
@@ -242,14 +236,8 @@ public class UTF8ZipFilesTest extends AbstractTestCase {
throws IOException {
final FileInputStream archive =
new FileInputStream(getFile("utf8-7zip-test.zip"));
- ZipArchiveInputStream zi = null;
- try {
- zi = new ZipArchiveInputStream(archive, CP437, false);
+ try (ZipArchiveInputStream zi = new ZipArchiveInputStream(archive, CP437, false)) {
assertRawNameOfAcsiiTxt((ZipArchiveEntry) zi.getNextEntry());
- } finally {
- if (zi != null) {
- zi.close();
- }
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/zip/Zip64SupportIT.java b/src/test/java/org/apache/commons/compress/archivers/zip/Zip64SupportIT.java
index 729eeda..a758fd2 100644
--- a/src/test/java/org/apache/commons/compress/archivers/zip/Zip64SupportIT.java
+++ b/src/test/java/org/apache/commons/compress/archivers/zip/Zip64SupportIT.java
@@ -2448,10 +2448,8 @@ public class Zip64SupportIT {
private static void read5GBOfZerosImpl(final File f, final String expectedName)
throws IOException {
- final FileInputStream fin = new FileInputStream(f);
- ZipArchiveInputStream zin = null;
- try {
- zin = new ZipArchiveInputStream(fin);
+ try (FileInputStream fin = new FileInputStream(f);
+ ZipArchiveInputStream zin = new ZipArchiveInputStream(fin)) {
ZipArchiveEntry zae = zin.getNextZipEntry();
while (zae.isDirectory()) {
zae = zin.getNextZipEntry();
@@ -2473,11 +2471,6 @@ public class Zip64SupportIT {
assertEquals(FIVE_BILLION, read);
assertNull(zin.getNextZipEntry());
assertEquals(FIVE_BILLION, zae.getSize());
- } finally {
- if (zin != null) {
- zin.close();
- }
- fin.close(); // fin cannot be null here
}
}
@@ -2518,10 +2511,8 @@ public class Zip64SupportIT {
}
private static void read100KFilesImpl(final File f) throws IOException {
- final FileInputStream fin = new FileInputStream(f);
- ZipArchiveInputStream zin = null;
- try {
- zin = new ZipArchiveInputStream(fin);
+ try (FileInputStream fin = new FileInputStream(f);
+ ZipArchiveInputStream zin = new ZipArchiveInputStream(fin)) {
int files = 0;
ZipArchiveEntry zae = null;
while ((zae = zin.getNextZipEntry()) != null) {
@@ -2531,11 +2522,6 @@ public class Zip64SupportIT {
}
}
assertEquals(ONE_HUNDRED_THOUSAND, files);
- } finally {
- if (zin != null) {
- zin.close();
- }
- fin.close();
}
}
diff --git a/src/test/java/org/apache/commons/compress/archivers/zip/ZipArchiveInputStreamTest.java b/src/test/java/org/apache/commons/compress/archivers/zip/ZipArchiveInputStreamTest.java
index c1112bc..ed7b7a7 100644
--- a/src/test/java/org/apache/commons/compress/archivers/zip/ZipArchiveInputStreamTest.java
+++ b/src/test/java/org/apache/commons/compress/archivers/zip/ZipArchiveInputStreamTest.java
@@ -60,17 +60,11 @@ public class ZipArchiveInputStreamTest {
*/
@Test
public void winzipBackSlashWorkaround() throws Exception {
- ZipArchiveInputStream in = null;
- try {
- in = new ZipArchiveInputStream(new FileInputStream(getFile("test-winzip.zip")));
+ try (ZipArchiveInputStream in = new ZipArchiveInputStream(new FileInputStream(getFile("test-winzip.zip")))) {
ZipArchiveEntry zae = in.getNextZipEntry();
zae = in.getNextZipEntry();
zae = in.getNextZipEntry();
assertEquals("\u00e4/", zae.getName());
- } finally {
- if (in != null) {
- in.close();
- }
}
}
@@ -123,14 +117,8 @@ public class ZipArchiveInputStreamTest {
*/
@Test
public void shouldReadNestedZip() throws IOException {
- ZipArchiveInputStream in = null;
- try {
- in = new ZipArchiveInputStream(new FileInputStream(getFile("COMPRESS-219.zip")));
+ try (ZipArchiveInputStream in = new ZipArchiveInputStream(new FileInputStream(getFile("COMPRESS-219.zip")))) {
extractZipInputStream(in);
- } finally {
- if (in != null) {
- in.close();
- }
}
}
@@ -265,9 +253,8 @@ public class ZipArchiveInputStreamTest {
final int expectedNumEntries = 2;
final InputStream is = ZipArchiveInputStreamTest.class
.getResourceAsStream("/archive_with_bytes_after_data.zip");
- final ZipArchiveInputStream zip = new ZipArchiveInputStream(is);
- try {
+ try (final ZipArchiveInputStream zip = new ZipArchiveInputStream(is)) {
int actualNumEntries = 0;
ZipArchiveEntry zae = zip.getNextZipEntry();
while (zae != null) {
@@ -276,8 +263,6 @@ public class ZipArchiveInputStreamTest {
zae = zip.getNextZipEntry();
}
assertEquals(expectedNumEntries, actualNumEntries);
- } finally {
- zip.close();
}
}
@@ -289,15 +274,12 @@ public class ZipArchiveInputStreamTest {
public void testThrowOnInvalidEntry() throws Exception {
final InputStream is = ZipArchiveInputStreamTest.class
.getResourceAsStream("/invalid-zip.zip");
- final ZipArchiveInputStream zip = new ZipArchiveInputStream(is);
- try {
+ try (final ZipArchiveInputStream zip = new ZipArchiveInputStream(is)) {
zip.getNextZipEntry();
fail("IOException expected");
} catch (final ZipException expected) {
assertTrue(expected.getMessage().contains("Unexpected record signature"));
- } finally {
- zip.close();
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/DeflateTestCase.java b/src/test/java/org/apache/commons/compress/compressors/DeflateTestCase.java
index 468cb57..c4e4a09 100644
--- a/src/test/java/org/apache/commons/compress/compressors/DeflateTestCase.java
+++ b/src/test/java/org/apache/commons/compress/compressors/DeflateTestCase.java
@@ -78,17 +78,11 @@ public final class DeflateTestCase extends AbstractTestCase {
final File input = getFile("bla.tar.deflatez");
final File output = new File(dir, "bla.tar");
try (InputStream is = new FileInputStream(input)) {
- final CompressorInputStream in = new CompressorStreamFactory()
- .createCompressorInputStream("deflate", is); // zlib header is expected by default
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ // zlib header is expected by default
+ try (CompressorInputStream in = new CompressorStreamFactory()
+ .createCompressorInputStream("deflate", is);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
@@ -105,16 +99,9 @@ public final class DeflateTestCase extends AbstractTestCase {
try (InputStream is = new FileInputStream(input)) {
final DeflateParameters params = new DeflateParameters();
params.setWithZlibHeader(false);
- final CompressorInputStream in = new DeflateCompressorInputStream(is, params);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ try (CompressorInputStream in = new DeflateCompressorInputStream(is, params);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/FramedSnappyTestCase.java b/src/test/java/org/apache/commons/compress/compressors/FramedSnappyTestCase.java
index ec0f38e..1313e9b 100644
--- a/src/test/java/org/apache/commons/compress/compressors/FramedSnappyTestCase.java
+++ b/src/test/java/org/apache/commons/compress/compressors/FramedSnappyTestCase.java
@@ -57,17 +57,10 @@ public final class FramedSnappyTestCase
try (FileInputStream is = new FileInputStream(input)) {
// the intermediate BufferedInputStream is there for mark
// support in the autodetection test
- final CompressorInputStream in = wrapper.wrap(new BufferedInputStream(is));
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ try (CompressorInputStream in = wrapper.wrap(new BufferedInputStream(is));
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
assertEquals(995, in.getBytesRead());
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
final File original = getFile("bla.tar");
diff --git a/src/test/java/org/apache/commons/compress/compressors/GZipTestCase.java b/src/test/java/org/apache/commons/compress/compressors/GZipTestCase.java
index cf72611..d22822d 100644
--- a/src/test/java/org/apache/commons/compress/compressors/GZipTestCase.java
+++ b/src/test/java/org/apache/commons/compress/compressors/GZipTestCase.java
@@ -58,17 +58,10 @@ public final class GZipTestCase extends AbstractTestCase {
final File input = getFile("bla.tgz");
final File output = new File(dir, "bla.tar");
try (InputStream is = new FileInputStream(input)) {
- final CompressorInputStream in = new CompressorStreamFactory()
+ try (CompressorInputStream in = new CompressorStreamFactory()
.createCompressorInputStream("gz", is);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/LZMATestCase.java b/src/test/java/org/apache/commons/compress/compressors/LZMATestCase.java
index d5c717c..ad8c247 100644
--- a/src/test/java/org/apache/commons/compress/compressors/LZMATestCase.java
+++ b/src/test/java/org/apache/commons/compress/compressors/LZMATestCase.java
@@ -105,14 +105,9 @@ public final class LZMATestCase extends AbstractTestCase {
}
private void copy(final InputStream in, final File output) throws IOException {
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ try (FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
} finally {
- if (out != null) {
- out.close();
- }
in.close();
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/XZTestCase.java b/src/test/java/org/apache/commons/compress/compressors/XZTestCase.java
index cd605a9..f6cc028 100644
--- a/src/test/java/org/apache/commons/compress/compressors/XZTestCase.java
+++ b/src/test/java/org/apache/commons/compress/compressors/XZTestCase.java
@@ -53,17 +53,10 @@ public final class XZTestCase extends AbstractTestCase {
final File input = getFile("bla.tar.xz");
final File output = new File(dir, "bla.tar");
try (InputStream is = new FileInputStream(input)) {
- final CompressorInputStream in = new CompressorStreamFactory()
+ try (CompressorInputStream in = new CompressorStreamFactory()
.createCompressorInputStream("xz", is);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/ZTestCase.java b/src/test/java/org/apache/commons/compress/compressors/ZTestCase.java
index 5e576df..10774aa 100644
--- a/src/test/java/org/apache/commons/compress/compressors/ZTestCase.java
+++ b/src/test/java/org/apache/commons/compress/compressors/ZTestCase.java
@@ -66,16 +66,9 @@ public final class ZTestCase extends AbstractTestCase {
final File input = getFile("bla.tar.Z");
final File output = new File(dir, "bla.tar");
try (InputStream is = new FileInputStream(input)) {
- final InputStream in = wrapper.wrap(is);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ try (InputStream in = wrapper.wrap(is);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/brotli/BrotliCompressorInputStreamTest.java b/src/test/java/org/apache/commons/compress/compressors/brotli/BrotliCompressorInputStreamTest.java
index 579f451..51e7cea 100644
--- a/src/test/java/org/apache/commons/compress/compressors/brotli/BrotliCompressorInputStreamTest.java
+++ b/src/test/java/org/apache/commons/compress/compressors/brotli/BrotliCompressorInputStreamTest.java
@@ -153,17 +153,10 @@ public class BrotliCompressorInputStreamTest extends AbstractTestCase {
final File input = getFile("bla.tar.br");
final File output = new File(dir, "bla.tar");
try (InputStream is = new FileInputStream(input)) {
- final CompressorInputStream in = new CompressorStreamFactory()
+ try (CompressorInputStream in = new CompressorStreamFactory()
.createCompressorInputStream("br", is);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStreamTest.java b/src/test/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStreamTest.java
index db985ba..d129990 100644
--- a/src/test/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStreamTest.java
+++ b/src/test/java/org/apache/commons/compress/compressors/snappy/FramedSnappyCompressorInputStreamTest.java
@@ -150,17 +150,10 @@ public final class FramedSnappyCompressorInputStreamTest
public void readIWAFile() throws Exception {
try (ZipFile zip = new ZipFile(getFile("testNumbersNew.numbers"))) {
try (InputStream is = zip.getInputStream(zip.getEntry("Index/Document.iwa"))) {
- final FramedSnappyCompressorInputStream in =
+ try (FramedSnappyCompressorInputStream in =
new FramedSnappyCompressorInputStream(is, FramedSnappyDialect.IWORK_ARCHIVE);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(new File(dir, "snappyIWATest.raw"));
+ FileOutputStream out = new FileOutputStream(new File(dir, "snappyIWATest.raw"))) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}
diff --git a/src/test/java/org/apache/commons/compress/compressors/zstandard/ZstdCompressorInputStreamTest.java b/src/test/java/org/apache/commons/compress/compressors/zstandard/ZstdCompressorInputStreamTest.java
index ccc9c18..4bedd3b 100644
--- a/src/test/java/org/apache/commons/compress/compressors/zstandard/ZstdCompressorInputStreamTest.java
+++ b/src/test/java/org/apache/commons/compress/compressors/zstandard/ZstdCompressorInputStreamTest.java
@@ -153,17 +153,10 @@ public class ZstdCompressorInputStreamTest extends AbstractTestCase {
final File input = getFile("bla.tar.zst");
final File output = new File(dir, "bla.tar");
try (InputStream is = new FileInputStream(input)) {
- final CompressorInputStream in = new CompressorStreamFactory()
+ try (CompressorInputStream in = new CompressorStreamFactory()
.createCompressorInputStream("zstd", is);
- FileOutputStream out = null;
- try {
- out = new FileOutputStream(output);
+ FileOutputStream out = new FileOutputStream(output)) {
IOUtils.copy(in, out);
- } finally {
- if (out != null) {
- out.close();
- }
- in.close();
}
}
}