Channel concept & implementation— el Project (2)

DefaultChannelPipeline.java

public class DefaultChannelPipeline implements ChannelPipeline {

  @Override
  public ChannelPromise bind(SocketAddress localAddress) {
    return this.tailContext.bind(localAddress);
  }

  @Override
  public ChannelPromise bind(SocketAddress localAddress, ChannelPromise promise) {
    return this.tailContext.bind(localAddress, promise);
  }

  @Override
  public ChannelPromise connect(SocketAddress remoteAddress, ChannelPromise promise) {
    return this.tailContext.connect(remoteAddress, promise);
  }
  
  private static final class TailContext extends AbstractChannelHandlerContext {

    private final TailContextHandler handler;

    public TailContext(ChannelPipeline pipeline) {
      super(HEAD_NAME, pipeline, null, TailContextHandler.class);
      this.handler = new TailContextHandler();
    }

    @Override
    public ChannelHandler handler() {
      return this.handler;
    }
  }
}