diff --git a/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java b/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java index bebf2d5e58..bd9415b17b 100644 --- a/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java +++ b/transport/src/test/java/io/netty/channel/ChannelInitializerTest.java @@ -335,7 +335,7 @@ public class ChannelInitializerTest { } @Override - public void channelUnregistered(ChannelHandlerContext ctx) { + public void handlerRemoved(ChannelHandlerContext ctx) { latch.countDown(); } }); @@ -369,6 +369,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());