You are viewing a plain text version of this content. The canonical link for it is here.

Posted to oak-commits@jackrabbit.apache.org by fr...@apache.org on 2017/12/05 17:11:11 UTC

svn commit: r1817218 - /jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoderTest.java

Author: frm
Date: Tue Dec  5 17:11:10 2017
New Revision: 1817218

URL: http://svn.apache.org/viewvc?rev=1817218&view=rev
Log:
OAK-6896 - Always close the returned InputStream in ResponseDecoderTest#shouldDecodeValidTwoChunksGetBlobResponses

Modified:
    jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoderTest.java

Modified: jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoderTest.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoderTest.java?rev=1817218&r1=1817217&r2=1817218&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoderTest.java (original)
+++ jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/codec/ResponseDecoderTest.java Tue Dec  5 17:11:10 2017
@@ -92,8 +92,10 @@ public class ResponseDecoderTest {
         GetBlobResponse response = (GetBlobResponse) channel.readInbound();
         assertEquals("blobId", response.getBlobId());
         assertEquals(blobData.length, response.getLength());
-        byte[] receivedData = IOUtils.toByteArray(response.getInputStream());
-        assertArrayEquals(blobData, receivedData);
+        try (InputStream is = response.getInputStream()) {
+            byte[] receivedData = IOUtils.toByteArray(is);
+            assertArrayEquals(blobData, receivedData);
+        }
     }
 
     @Test