Channel concept & implementation— el Project (2)

AbstractTransport.java

public abstract class AbstractTransport<T extends AbstractTransport<T, C>, C extends Channel> {

  public ChannelPromise bind(SocketAddress localAddress) {
    doBind(...);
  }
  
  private void doBind(
    final ChannelPromise registered,
    final Channel channel,
    final SocketAddress localAddress,     
    final ChannelPromise result) {
    channel
        .channelEventLoop()
        .execute(
            () -> {
              channel
                  .bind(localAddress)
                  .addListener(
                      promise -> {
                        if (promise.isSuccess()) {
                          result.setSuccess(null);
                          return;
                        }
                        result.setFailure(promise.cause());
                      });
              return;
            });
  }
}