DefaultChannelPipelineTest.java 文件源码

@Test
public void testRemoveChannelHandler() {
    ChannelPipeline pipeline = new LocalChannel(group.next()).pipeline();

    ChannelHandler handler1 = newHandler();
    ChannelHandler handler2 = newHandler();
    ChannelHandler handler3 = newHandler();

    pipeline.addLast("handler1", handler1);
    pipeline.addLast("handler2", handler2);
    pipeline.addLast("handler3", handler3);
    assertSame(pipeline.get("handler1"), handler1);
    assertSame(pipeline.get("handler2"), handler2);
    assertSame(pipeline.get("handler3"), handler3);

    pipeline.remove(handler1);
    pipeline.remove(handler2);
    pipeline.remove(handler3);
}