Channel concept & implementation— el Project (2)

LocalChannel.java

public class LocalChannel extends AbstractChannel {
  ...
  protected void doConnect(LocalServerChannel server, ChannelPromise result) {
    this.server = server;
    server.connectFrom(this);
    state = State.CONNECTED;
    remoteAddress = this.server.localAddress();
    result.setSuccess(null);
  }
  ...
  private class LocalInternal extends AbstractInternal {
    @Override
    public void connect(SocketAddress remoteAddress, ChannelPromise promise) {
      ...
      Channel boundChannel = LocalChannelRegistry.get(remoteAddress);
      if (!(boundChannel instanceof LocalServerChannel)) {
        Exception cause = new ConnectException("Connection refused: " + remoteAddress);
        promise.setFailure(cause);
        return;
      }

      doConnect((LocalServerChannel) boundChannel, promise);
    }
  }
}