diff --git a/codec/src/test/java/io/netty/handler/codec/compression/Bzip2EncoderTest.java b/codec/src/test/java/io/netty/handler/codec/compression/Bzip2EncoderTest.java index 466b455f79..295802e63f 100644 --- a/codec/src/test/java/io/netty/handler/codec/compression/Bzip2EncoderTest.java +++ b/codec/src/test/java/io/netty/handler/codec/compression/Bzip2EncoderTest.java @@ -54,7 +54,10 @@ public class Bzip2EncoderTest { assertEquals(9 + '0', out.readByte()); out.release(); - channel.finish(); + assertTrue(channel.finish()); + out = channel.readOutbound(); + out.release(); + assertNull(channel.readOutbound()); } private static void testCompression(final byte[] data) throws Exception {