diff --git a/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java b/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java index 38d867ab19..24e6b5e77f 100644 --- a/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java +++ b/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java @@ -338,7 +338,7 @@ public class ChannelInitializerTest { } @Override - public void channelUnregistered(ChannelHandlerContext ctx) { + public void handlerRemoved(ChannelHandlerContext ctx) { latch.countDown(); } }); @@ -372,6 +372,7 @@ public class ChannelInitializerTest { client.closeFuture().sync(); server.closeFuture().sync(); + // Wait until the handler is removed from the pipeline and so no more events are handled by it. latch.await(); assertEquals(1, invokeCount.get());