From a0378af850963ec1961f6212ec32d770bd4f3586 Mon Sep 17 00:00:00 2001
From: Trustin Lee <t@motd.kr>
Date: Sun, 16 Feb 2014 11:49:25 -0800
Subject: [PATCH] Fix resource leaks in ByteArrayEncoderTest

---
 .../codec/bytes/ByteArrayEncoderTest.java        | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git a/codec/src/test/java/io/netty/handler/codec/bytes/ByteArrayEncoderTest.java b/codec/src/test/java/io/netty/handler/codec/bytes/ByteArrayEncoderTest.java
index 486832c972..bf76071e69 100644
--- a/codec/src/test/java/io/netty/handler/codec/bytes/ByteArrayEncoderTest.java
+++ b/codec/src/test/java/io/netty/handler/codec/bytes/ByteArrayEncoderTest.java
@@ -18,17 +18,16 @@ package io.netty.handler.codec.bytes;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.embedded.EmbeddedChannel;
 import io.netty.util.internal.EmptyArrays;
+import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
 import java.util.Random;
 
 import static io.netty.buffer.Unpooled.*;
-import static org.hamcrest.core.Is.*;
-import static org.hamcrest.core.IsNull.*;
+import static org.hamcrest.CoreMatchers.*;
 import static org.junit.Assert.*;
 
-@SuppressWarnings("ZeroLengthArrayAllocation")
 public class ByteArrayEncoderTest {
 
     private EmbeddedChannel ch;
@@ -38,18 +37,25 @@ public class ByteArrayEncoderTest {
         ch = new EmbeddedChannel(new ByteArrayEncoder());
     }
 
+    @After
+    public void tearDown() {
+        assertThat(ch.finish(), is(false));
+    }
+
     @Test
     public void testEncode() {
         byte[] b = new byte[2048];
         new Random().nextBytes(b);
         ch.writeOutbound(b);
-        assertThat((ByteBuf) ch.readOutbound(), is(wrappedBuffer(b)));
+        ByteBuf encoded = ch.readOutbound();
+        assertThat(encoded, is(wrappedBuffer(b)));
+        encoded.release();
     }
 
     @Test
     public void testEncodeEmpty() {
         ch.writeOutbound(EmptyArrays.EMPTY_BYTES);
-        assertThat((ByteBuf) ch.readOutbound(), is(EMPTY_BUFFER));
+        assertThat((ByteBuf) ch.readOutbound(), is(sameInstance(EMPTY_BUFFER)));
     }
 
     @Test