http://netty.io/netty-all/: Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers and clients. (The Netty Project) 
public abstract class io.netty.handler.proxy.ProxyHandler extends io.netty.channel.ChannelDuplexHandler
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: io.netty.handler.proxy.ProxyHandler
  super_class: io.netty.channel.ChannelDuplexHandler
{
  private static final io.netty.util.internal.logging.InternalLogger logger;
    descriptor: Lio/netty/util/internal/logging/InternalLogger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final long DEFAULT_CONNECT_TIMEOUT_MILLIS;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 10000

  static final java.lang.String AUTH_NONE;
    descriptor: Ljava/lang/String;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: "none"

  private final java.net.SocketAddress proxyAddress;
    descriptor: Ljava/net/SocketAddress;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private volatile java.net.SocketAddress destinationAddress;
    descriptor: Ljava/net/SocketAddress;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile long connectTimeoutMillis;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile io.netty.channel.ChannelHandlerContext ctx;
    descriptor: Lio/netty/channel/ChannelHandlerContext;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private io.netty.channel.PendingWriteQueue pendingWrites;
    descriptor: Lio/netty/channel/PendingWriteQueue;
    flags: (0x0002) ACC_PRIVATE

  private boolean finished;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean suppressChannelReadComplete;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean flushedPrematurely;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private final io.netty.handler.proxy.ProxyHandler$LazyChannelPromise connectPromise;
    descriptor: Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.netty.util.concurrent.ScheduledFuture<?> connectTimeoutFuture;
    descriptor: Lio/netty/util/concurrent/ScheduledFuture;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/netty/util/concurrent/ScheduledFuture<*>;

  private final io.netty.channel.ChannelFutureListener writeListener;
    descriptor: Lio/netty/channel/ChannelFutureListener;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 40
            ldc Lio/netty/handler/proxy/ProxyHandler;
            invokestatic io.netty.util.internal.logging.InternalLoggerFactory.getInstance:(Ljava/lang/Class;)Lio/netty/util/internal/logging/InternalLogger;
            putstatic io.netty.handler.proxy.ProxyHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
         1: .line 50
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  protected void <init>(java.net.SocketAddress);
    descriptor: (Ljava/net/SocketAddress;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // java.net.SocketAddress proxyAddress
         0: .line 72
            aload 0 /* this */
            invokespecial io.netty.channel.ChannelDuplexHandler.<init>:()V
         1: .line 54
            aload 0 /* this */
            ldc 10000
            putfield io.netty.handler.proxy.ProxyHandler.connectTimeoutMillis:J
         2: .line 61
            aload 0 /* this */
            new io.netty.handler.proxy.ProxyHandler$LazyChannelPromise
            dup
            aload 0 /* this */
            invokespecial io.netty.handler.proxy.ProxyHandler$LazyChannelPromise.<init>:(Lio/netty/handler/proxy/ProxyHandler;)V
            putfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
         3: .line 63
            aload 0 /* this */
            new io.netty.handler.proxy.ProxyHandler$1
            dup
            aload 0 /* this */
            invokespecial io.netty.handler.proxy.ProxyHandler$1.<init>:(Lio/netty/handler/proxy/ProxyHandler;)V
            putfield io.netty.handler.proxy.ProxyHandler.writeListener:Lio/netty/channel/ChannelFutureListener;
         4: .line 73
            aload 1 /* proxyAddress */
            ifnonnull 6
         5: .line 74
            new java.lang.NullPointerException
            dup
            ldc "proxyAddress"
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 76
      StackMap locals: io.netty.handler.proxy.ProxyHandler java.net.SocketAddress
      StackMap stack:
            aload 0 /* this */
            aload 1 /* proxyAddress */
            putfield io.netty.handler.proxy.ProxyHandler.proxyAddress:Ljava/net/SocketAddress;
         7: .line 77
            return
        end local 1 // java.net.SocketAddress proxyAddress
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    8     0          this  Lio/netty/handler/proxy/ProxyHandler;
            0    8     1  proxyAddress  Ljava/net/SocketAddress;
    MethodParameters:
              Name  Flags
      proxyAddress  

  public abstract java.lang.String protocol();
    descriptor: ()Ljava/lang/String;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public abstract java.lang.String authScheme();
    descriptor: ()Ljava/lang/String;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public final <T extends java.net.SocketAddress> T proxyAddress();
    descriptor: ()Ljava/net/SocketAddress;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 94
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.proxyAddress:Ljava/net/SocketAddress;
            areturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/proxy/ProxyHandler;
    Signature: <T:Ljava/net/SocketAddress;>()TT;

  public final <T extends java.net.SocketAddress> T destinationAddress();
    descriptor: ()Ljava/net/SocketAddress;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 102
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.destinationAddress:Ljava/net/SocketAddress;
            areturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/proxy/ProxyHandler;
    Signature: <T:Ljava/net/SocketAddress;>()TT;

  public final boolean isConnected();
    descriptor: ()Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 109
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
            invokevirtual io.netty.handler.proxy.ProxyHandler$LazyChannelPromise.isSuccess:()Z
            ireturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/proxy/ProxyHandler;

  public final io.netty.util.concurrent.Future<io.netty.channel.Channel> connectFuture();
    descriptor: ()Lio/netty/util/concurrent/Future;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 117
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
            areturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/proxy/ProxyHandler;
    Signature: ()Lio/netty/util/concurrent/Future<Lio/netty/channel/Channel;>;

  public final long connectTimeoutMillis();
    descriptor: ()J
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 125
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectTimeoutMillis:J
            lreturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/proxy/ProxyHandler;

  public final void setConnectTimeoutMillis(long);
    descriptor: (J)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // long connectTimeoutMillis
         0: .line 133
            lload 1 /* connectTimeoutMillis */
            lconst_0
            lcmp
            ifgt 2
         1: .line 134
            lconst_0
            lstore 1 /* connectTimeoutMillis */
         2: .line 137
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 1 /* connectTimeoutMillis */
            putfield io.netty.handler.proxy.ProxyHandler.connectTimeoutMillis:J
         3: .line 138
            return
        end local 1 // long connectTimeoutMillis
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0    4     0                  this  Lio/netty/handler/proxy/ProxyHandler;
            0    4     1  connectTimeoutMillis  J
    MethodParameters:
                      Name  Flags
      connectTimeoutMillis  

  public final void handlerAdded(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 142
            aload 0 /* this */
            aload 1 /* ctx */
            putfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
         1: .line 143
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.proxy.ProxyHandler.addCodec:(Lio/netty/channel/ChannelHandlerContext;)V
         2: .line 145
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.isActive:()Z
            ifeq 4
         3: .line 148
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.proxy.ProxyHandler.sendInitialMessage:(Lio/netty/channel/ChannelHandlerContext;)V
         4: .line 153
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0    5     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  protected abstract void addCodec(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  protected abstract void removeEncoder(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  protected abstract void removeDecoder(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public final void connect(io.netty.channel.ChannelHandlerContext, java.net.SocketAddress, java.net.SocketAddress, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lio/netty/channel/ChannelPromise;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=5, args_size=5
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.net.SocketAddress remoteAddress
        start local 3 // java.net.SocketAddress localAddress
        start local 4 // io.netty.channel.ChannelPromise promise
         0: .line 175
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.destinationAddress:Ljava/net/SocketAddress;
            ifnull 3
         1: .line 176
            aload 4 /* promise */
            new java.nio.channels.ConnectionPendingException
            dup
            invokespecial java.nio.channels.ConnectionPendingException.<init>:()V
            invokeinterface io.netty.channel.ChannelPromise.setFailure:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPromise;
            pop
         2: .line 177
            return
         3: .line 180
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* remoteAddress */
            putfield io.netty.handler.proxy.ProxyHandler.destinationAddress:Ljava/net/SocketAddress;
         4: .line 181
            aload 1 /* ctx */
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.proxyAddress:Ljava/net/SocketAddress;
            aload 3 /* localAddress */
            aload 4 /* promise */
            invokeinterface io.netty.channel.ChannelHandlerContext.connect:(Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            pop
         5: .line 182
            return
        end local 4 // io.netty.channel.ChannelPromise promise
        end local 3 // java.net.SocketAddress localAddress
        end local 2 // java.net.SocketAddress remoteAddress
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    6     0           this  Lio/netty/handler/proxy/ProxyHandler;
            0    6     1            ctx  Lio/netty/channel/ChannelHandlerContext;
            0    6     2  remoteAddress  Ljava/net/SocketAddress;
            0    6     3   localAddress  Ljava/net/SocketAddress;
            0    6     4        promise  Lio/netty/channel/ChannelPromise;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
               Name  Flags
      ctx            
      remoteAddress  
      localAddress   
      promise        

  public final void channelActive(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 186
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.proxy.ProxyHandler.sendInitialMessage:(Lio/netty/channel/ChannelHandlerContext;)V
         1: .line 187
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelActive:()Lio/netty/channel/ChannelHandlerContext;
            pop
         2: .line 188
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0    3     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  private void sendInitialMessage(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=5, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 195
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectTimeoutMillis:J
            lstore 2 /* connectTimeoutMillis */
        start local 2 // long connectTimeoutMillis
         1: .line 196
            lload 2 /* connectTimeoutMillis */
            lconst_0
            lcmp
            ifle 5
         2: .line 197
            aload 0 /* this */
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            new io.netty.handler.proxy.ProxyHandler$2
            dup
            aload 0 /* this */
            invokespecial io.netty.handler.proxy.ProxyHandler$2.<init>:(Lio/netty/handler/proxy/ProxyHandler;)V
         3: .line 204
            lload 2 /* connectTimeoutMillis */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
         4: .line 197
            invokeinterface io.netty.util.concurrent.EventExecutor.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture;
            putfield io.netty.handler.proxy.ProxyHandler.connectTimeoutFuture:Lio/netty/util/concurrent/ScheduledFuture;
         5: .line 207
      StackMap locals: long
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            invokevirtual io.netty.handler.proxy.ProxyHandler.newInitialMessage:(Lio/netty/channel/ChannelHandlerContext;)Ljava/lang/Object;
            astore 4 /* initialMessage */
        start local 4 // java.lang.Object initialMessage
         6: .line 208
            aload 4 /* initialMessage */
            ifnull 8
         7: .line 209
            aload 0 /* this */
            aload 4 /* initialMessage */
            invokevirtual io.netty.handler.proxy.ProxyHandler.sendToProxyServer:(Ljava/lang/Object;)V
         8: .line 212
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 1 /* ctx */
            invokestatic io.netty.handler.proxy.ProxyHandler.readIfNeeded:(Lio/netty/channel/ChannelHandlerContext;)V
         9: .line 213
            return
        end local 4 // java.lang.Object initialMessage
        end local 2 // long connectTimeoutMillis
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   10     0                  this  Lio/netty/handler/proxy/ProxyHandler;
            0   10     1                   ctx  Lio/netty/channel/ChannelHandlerContext;
            1   10     2  connectTimeoutMillis  J
            6   10     4        initialMessage  Ljava/lang/Object;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   final

  protected abstract java.lang.Object newInitialMessage(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)Ljava/lang/Object;
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  protected final void sendToProxyServer(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // java.lang.Object msg
         0: .line 227
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            aload 1 /* msg */
            invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.writeListener:Lio/netty/channel/ChannelFutureListener;
            invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
            pop
         1: .line 228
            return
        end local 1 // java.lang.Object msg
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0    2     1   msg  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      msg   

  public final void channelInactive(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 232
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.finished:Z
            ifeq 3
         1: .line 233
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelInactive:()Lio/netty/channel/ChannelHandlerContext;
            pop
         2: .line 234
            goto 4
         3: .line 236
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new io.netty.handler.proxy.ProxyConnectException
            dup
            aload 0 /* this */
            ldc "disconnected"
            invokevirtual io.netty.handler.proxy.ProxyHandler.exceptionMessage:(Ljava/lang/String;)Ljava/lang/String;
            invokespecial io.netty.handler.proxy.ProxyConnectException.<init>:(Ljava/lang/String;)V
            invokevirtual io.netty.handler.proxy.ProxyHandler.setConnectFailure:(Ljava/lang/Throwable;)V
         4: .line 238
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0    5     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public final void exceptionCaught(io.netty.channel.ChannelHandlerContext, java.lang.Throwable);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Throwable cause
         0: .line 242
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.finished:Z
            ifeq 3
         1: .line 243
            aload 1 /* ctx */
            aload 2 /* cause */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelHandlerContext;
            pop
         2: .line 244
            goto 4
         3: .line 246
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.setConnectFailure:(Ljava/lang/Throwable;)V
         4: .line 248
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Throwable cause
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lio/netty/handler/proxy/ProxyHandler;
            0    5     1    ctx  Lio/netty/channel/ChannelHandlerContext;
            0    5     2  cause  Ljava/lang/Throwable;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
       Name  Flags
      ctx    
      cause  

  public final void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=6, args_size=3
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
         0: .line 252
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.finished:Z
            ifeq 4
         1: .line 254
            aload 0 /* this */
            iconst_0
            putfield io.netty.handler.proxy.ProxyHandler.suppressChannelReadComplete:Z
         2: .line 255
            aload 1 /* ctx */
            aload 2 /* msg */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
            pop
         3: .line 256
            goto 23
         4: .line 257
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.netty.handler.proxy.ProxyHandler.suppressChannelReadComplete:Z
         5: .line 258
            aconst_null
            astore 3 /* cause */
        start local 3 // java.lang.Throwable cause
         6: .line 260
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* msg */
            invokevirtual io.netty.handler.proxy.ProxyHandler.handleResponse:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)Z
            istore 4 /* done */
        start local 4 // boolean done
         7: .line 261
            iload 4 /* done */
            ifeq 20
         8: .line 262
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.setConnectSuccess:()V
        end local 4 // boolean done
         9: .line 264
            goto 20
      StackMap locals: io.netty.handler.proxy.ProxyHandler io.netty.channel.ChannelHandlerContext java.lang.Object java.lang.Throwable
      StackMap stack: java.lang.Throwable
        10: astore 4 /* t */
        start local 4 // java.lang.Throwable t
        11: .line 265
            aload 4 /* t */
            astore 3 /* cause */
        end local 4 // java.lang.Throwable t
        12: .line 267
            aload 2 /* msg */
            invokestatic io.netty.util.ReferenceCountUtil.release:(Ljava/lang/Object;)Z
            pop
        13: .line 268
            aload 3 /* cause */
            ifnull 23
        14: .line 269
            aload 0 /* this */
            aload 3 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.setConnectFailure:(Ljava/lang/Throwable;)V
            goto 23
        15: .line 266
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 5
        16: .line 267
            aload 2 /* msg */
            invokestatic io.netty.util.ReferenceCountUtil.release:(Ljava/lang/Object;)Z
            pop
        17: .line 268
            aload 3 /* cause */
            ifnull 19
        18: .line 269
            aload 0 /* this */
            aload 3 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.setConnectFailure:(Ljava/lang/Throwable;)V
        19: .line 271
      StackMap locals: io.netty.handler.proxy.ProxyHandler io.netty.channel.ChannelHandlerContext java.lang.Object java.lang.Throwable top java.lang.Throwable
      StackMap stack:
            aload 5
            athrow
        20: .line 267
      StackMap locals: io.netty.handler.proxy.ProxyHandler io.netty.channel.ChannelHandlerContext java.lang.Object java.lang.Throwable
      StackMap stack:
            aload 2 /* msg */
            invokestatic io.netty.util.ReferenceCountUtil.release:(Ljava/lang/Object;)Z
            pop
        21: .line 268
            aload 3 /* cause */
            ifnull 23
        22: .line 269
            aload 0 /* this */
            aload 3 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.setConnectFailure:(Ljava/lang/Throwable;)V
        end local 3 // java.lang.Throwable cause
        23: .line 273
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   24     0   this  Lio/netty/handler/proxy/ProxyHandler;
            0   24     1    ctx  Lio/netty/channel/ChannelHandlerContext;
            0   24     2    msg  Ljava/lang/Object;
            6   23     3  cause  Ljava/lang/Throwable;
            7    9     4   done  Z
           11   12     4      t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           6     9      10  Class java.lang.Throwable
           6    12      15  any
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   
      msg   

  protected abstract boolean handleResponse(io.netty.channel.ChannelHandlerContext, java.lang.Object);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)Z
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
          Name  Flags
      ctx       
      response  

  private void setConnectSuccess();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=3, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 285
            aload 0 /* this */
            iconst_1
            putfield io.netty.handler.proxy.ProxyHandler.finished:Z
         1: .line 286
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.cancelConnectTimeoutFuture:()V
         2: .line 288
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
            invokevirtual io.netty.handler.proxy.ProxyHandler$LazyChannelPromise.isDone:()Z
            ifne 19
         3: .line 289
            iconst_1
            istore 1 /* removedCodec */
        start local 1 // boolean removedCodec
         4: .line 291
            iload 1 /* removedCodec */
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.safeRemoveEncoder:()Z
            iand
            istore 1 /* removedCodec */
         5: .line 293
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
         6: .line 294
            new io.netty.handler.proxy.ProxyConnectionEvent
            dup
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.protocol:()Ljava/lang/String;
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.authScheme:()Ljava/lang/String;
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.proxyAddress:Ljava/net/SocketAddress;
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.destinationAddress:Ljava/net/SocketAddress;
            invokespecial io.netty.handler.proxy.ProxyConnectionEvent.<init>:(Ljava/lang/String;Ljava/lang/String;Ljava/net/SocketAddress;Ljava/net/SocketAddress;)V
         7: .line 293
            invokeinterface io.netty.channel.ChannelHandlerContext.fireUserEventTriggered:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
            pop
         8: .line 296
            iload 1 /* removedCodec */
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.safeRemoveDecoder:()Z
            iand
            istore 1 /* removedCodec */
         9: .line 298
            iload 1 /* removedCodec */
            ifeq 15
        10: .line 299
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.writePendingWrites:()V
        11: .line 301
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.flushedPrematurely:Z
            ifeq 13
        12: .line 302
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
            pop
        13: .line 304
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokevirtual io.netty.handler.proxy.ProxyHandler$LazyChannelPromise.trySuccess:(Ljava/lang/Object;)Z
            pop
        14: .line 305
            goto 19
        15: .line 307
      StackMap locals:
      StackMap stack:
            new io.netty.handler.proxy.ProxyConnectException
            dup
        16: .line 308
            ldc "failed to remove all codec handlers added by the proxy handler; bug?"
        17: .line 307
            invokespecial io.netty.handler.proxy.ProxyConnectException.<init>:(Ljava/lang/String;)V
            astore 2 /* cause */
        start local 2 // java.lang.Exception cause
        18: .line 309
            aload 0 /* this */
            aload 2 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.failPendingWritesAndClose:(Ljava/lang/Throwable;)V
        end local 2 // java.lang.Exception cause
        end local 1 // boolean removedCodec
        19: .line 312
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   20     0          this  Lio/netty/handler/proxy/ProxyHandler;
            4   19     1  removedCodec  Z
           18   19     2         cause  Ljava/lang/Exception;

  private boolean safeRemoveDecoder();
    descriptor: ()Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 316
            aload 0 /* this */
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokevirtual io.netty.handler.proxy.ProxyHandler.removeDecoder:(Lio/netty/channel/ChannelHandlerContext;)V
         1: .line 317
            iconst_1
            ireturn
         2: .line 318
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 1 /* e */
        start local 1 // java.lang.Exception e
         3: .line 319
            getstatic io.netty.handler.proxy.ProxyHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            ldc "Failed to remove proxy decoders:"
            aload 1 /* e */
            invokeinterface io.netty.util.internal.logging.InternalLogger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 1 // java.lang.Exception e
         4: .line 322
            iconst_0
            ireturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/netty/handler/proxy/ProxyHandler;
            3    4     1     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Exception

  private boolean safeRemoveEncoder();
    descriptor: ()Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 327
            aload 0 /* this */
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokevirtual io.netty.handler.proxy.ProxyHandler.removeEncoder:(Lio/netty/channel/ChannelHandlerContext;)V
         1: .line 328
            iconst_1
            ireturn
         2: .line 329
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 1 /* e */
        start local 1 // java.lang.Exception e
         3: .line 330
            getstatic io.netty.handler.proxy.ProxyHandler.logger:Lio/netty/util/internal/logging/InternalLogger;
            ldc "Failed to remove proxy encoders:"
            aload 1 /* e */
            invokeinterface io.netty.util.internal.logging.InternalLogger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 1 // java.lang.Exception e
         4: .line 333
            iconst_0
            ireturn
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/netty/handler/proxy/ProxyHandler;
            3    4     1     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Exception

  private void setConnectFailure(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // java.lang.Throwable cause
         0: .line 337
            aload 0 /* this */
            iconst_1
            putfield io.netty.handler.proxy.ProxyHandler.finished:Z
         1: .line 338
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.cancelConnectTimeoutFuture:()V
         2: .line 340
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
            invokevirtual io.netty.handler.proxy.ProxyHandler$LazyChannelPromise.isDone:()Z
            ifne 10
         3: .line 342
            aload 1 /* cause */
            instanceof io.netty.handler.proxy.ProxyConnectException
            ifne 7
         4: .line 343
            new io.netty.handler.proxy.ProxyConnectException
            dup
         5: .line 344
            aload 0 /* this */
            aload 1 /* cause */
            invokevirtual java.lang.Throwable.toString:()Ljava/lang/String;
            invokevirtual io.netty.handler.proxy.ProxyHandler.exceptionMessage:(Ljava/lang/String;)Ljava/lang/String;
            aload 1 /* cause */
         6: .line 343
            invokespecial io.netty.handler.proxy.ProxyConnectException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            astore 1 /* cause */
         7: .line 347
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.safeRemoveDecoder:()Z
            pop
         8: .line 348
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.safeRemoveEncoder:()Z
            pop
         9: .line 349
            aload 0 /* this */
            aload 1 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.failPendingWritesAndClose:(Ljava/lang/Throwable;)V
        10: .line 351
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   11     0   this  Lio/netty/handler/proxy/ProxyHandler;
            0   11     1  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  private void failPendingWritesAndClose(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // java.lang.Throwable cause
         0: .line 354
            aload 0 /* this */
            aload 1 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler.failPendingWrites:(Ljava/lang/Throwable;)V
         1: .line 355
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectPromise:Lio/netty/handler/proxy/ProxyHandler$LazyChannelPromise;
            aload 1 /* cause */
            invokevirtual io.netty.handler.proxy.ProxyHandler$LazyChannelPromise.tryFailure:(Ljava/lang/Throwable;)Z
            pop
         2: .line 356
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            aload 1 /* cause */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelHandlerContext;
            pop
         3: .line 357
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
            pop
         4: .line 358
            return
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lio/netty/handler/proxy/ProxyHandler;
            0    5     1  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  private void cancelConnectTimeoutFuture();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 361
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectTimeoutFuture:Lio/netty/util/concurrent/ScheduledFuture;
            ifnull 3
         1: .line 362
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.connectTimeoutFuture:Lio/netty/util/concurrent/ScheduledFuture;
            iconst_0
            invokeinterface io.netty.util.concurrent.ScheduledFuture.cancel:(Z)Z
            pop
         2: .line 363
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.proxy.ProxyHandler.connectTimeoutFuture:Lio/netty/util/concurrent/ScheduledFuture;
         3: .line 365
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/netty/handler/proxy/ProxyHandler;

  protected final java.lang.String exceptionMessage(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/String;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // java.lang.String msg
         0: .line 372
            aload 1 /* msg */
            ifnonnull 2
         1: .line 373
            ldc ""
            astore 1 /* msg */
         2: .line 376
      StackMap locals:
      StackMap stack:
            new java.lang.StringBuilder
            dup
            sipush 128
            aload 1 /* msg */
            invokevirtual java.lang.String.length:()I
            iadd
            invokespecial java.lang.StringBuilder.<init>:(I)V
         3: .line 377
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.protocol:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         4: .line 378
            ldc ", "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         5: .line 379
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.authScheme:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         6: .line 380
            ldc ", "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         7: .line 381
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.proxyAddress:Ljava/net/SocketAddress;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         8: .line 382
            ldc " => "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         9: .line 383
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.destinationAddress:Ljava/net/SocketAddress;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
        10: .line 376
            astore 2 /* buf */
        start local 2 // java.lang.StringBuilder buf
        11: .line 384
            aload 1 /* msg */
            invokevirtual java.lang.String.isEmpty:()Z
            ifne 13
        12: .line 385
            aload 2 /* buf */
            ldc ", "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* msg */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
        13: .line 388
      StackMap locals: java.lang.StringBuilder
      StackMap stack:
            aload 2 /* buf */
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 2 // java.lang.StringBuilder buf
        end local 1 // java.lang.String msg
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   14     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0   14     1   msg  Ljava/lang/String;
           11   14     2   buf  Ljava/lang/StringBuilder;
    MethodParameters:
      Name  Flags
      msg   

  public final void channelReadComplete(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 393
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.suppressChannelReadComplete:Z
            ifeq 4
         1: .line 394
            aload 0 /* this */
            iconst_0
            putfield io.netty.handler.proxy.ProxyHandler.suppressChannelReadComplete:Z
         2: .line 396
            aload 1 /* ctx */
            invokestatic io.netty.handler.proxy.ProxyHandler.readIfNeeded:(Lio/netty/channel/ChannelHandlerContext;)V
         3: .line 397
            goto 5
         4: .line 398
      StackMap locals:
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelReadComplete:()Lio/netty/channel/ChannelHandlerContext;
            pop
         5: .line 400
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0    6     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public final void write(io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
        start local 3 // io.netty.channel.ChannelPromise promise
         0: .line 404
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.finished:Z
            ifeq 4
         1: .line 405
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.writePendingWrites:()V
         2: .line 406
            aload 1 /* ctx */
            aload 2 /* msg */
            aload 3 /* promise */
            invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
            pop
         3: .line 407
            goto 5
         4: .line 408
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* msg */
            aload 3 /* promise */
            invokevirtual io.netty.handler.proxy.ProxyHandler.addPendingWrite:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
         5: .line 410
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.netty.channel.ChannelPromise promise
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0     this  Lio/netty/handler/proxy/ProxyHandler;
            0    6     1      ctx  Lio/netty/channel/ChannelHandlerContext;
            0    6     2      msg  Ljava/lang/Object;
            0    6     3  promise  Lio/netty/channel/ChannelPromise;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
         Name  Flags
      ctx      
      msg      
      promise  

  public final void flush(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 414
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.finished:Z
            ifeq 4
         1: .line 415
            aload 0 /* this */
            invokevirtual io.netty.handler.proxy.ProxyHandler.writePendingWrites:()V
         2: .line 416
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.flush:()Lio/netty/channel/ChannelHandlerContext;
            pop
         3: .line 417
            goto 5
         4: .line 418
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.netty.handler.proxy.ProxyHandler.flushedPrematurely:Z
         5: .line 420
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/netty/handler/proxy/ProxyHandler;
            0    6     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  private static void readIfNeeded(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 423
            aload 0 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.config:()Lio/netty/channel/ChannelConfig;
            invokeinterface io.netty.channel.ChannelConfig.isAutoRead:()Z
            ifne 2
         1: .line 424
            aload 0 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.read:()Lio/netty/channel/ChannelHandlerContext;
            pop
         2: .line 426
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.channel.ChannelHandlerContext ctx
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0   ctx  Lio/netty/channel/ChannelHandlerContext;
    MethodParameters:
      Name  Flags
      ctx   

  private void writePendingWrites();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.proxy.ProxyHandler this
         0: .line 429
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
            ifnull 3
         1: .line 430
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
            invokevirtual io.netty.channel.PendingWriteQueue.removeAndWriteAll:()Lio/netty/channel/ChannelFuture;
            pop
         2: .line 431
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
         3: .line 433
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/netty/handler/proxy/ProxyHandler;

  private void failPendingWrites(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // java.lang.Throwable cause
         0: .line 436
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
            ifnull 3
         1: .line 437
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
            aload 1 /* cause */
            invokevirtual io.netty.channel.PendingWriteQueue.removeAndFailAll:(Ljava/lang/Throwable;)V
         2: .line 438
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
         3: .line 440
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lio/netty/handler/proxy/ProxyHandler;
            0    4     1  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  private void addPendingWrite(io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=4
        start local 0 // io.netty.handler.proxy.ProxyHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
        start local 3 // io.netty.channel.ChannelPromise promise
         0: .line 443
            aload 0 /* this */
            getfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
            astore 4 /* pendingWrites */
        start local 4 // io.netty.channel.PendingWriteQueue pendingWrites
         1: .line 444
            aload 4 /* pendingWrites */
            ifnonnull 3
         2: .line 445
            aload 0 /* this */
            new io.netty.channel.PendingWriteQueue
            dup
            aload 1 /* ctx */
            invokespecial io.netty.channel.PendingWriteQueue.<init>:(Lio/netty/channel/ChannelHandlerContext;)V
            dup
            astore 4 /* pendingWrites */
            putfield io.netty.handler.proxy.ProxyHandler.pendingWrites:Lio/netty/channel/PendingWriteQueue;
         3: .line 447
      StackMap locals: io.netty.channel.PendingWriteQueue
      StackMap stack:
            aload 4 /* pendingWrites */
            aload 2 /* msg */
            aload 3 /* promise */
            invokevirtual io.netty.channel.PendingWriteQueue.add:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
         4: .line 448
            return
        end local 4 // io.netty.channel.PendingWriteQueue pendingWrites
        end local 3 // io.netty.channel.ChannelPromise promise
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.proxy.ProxyHandler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0           this  Lio/netty/handler/proxy/ProxyHandler;
            0    5     1            ctx  Lio/netty/channel/ChannelHandlerContext;
            0    5     2            msg  Ljava/lang/Object;
            0    5     3        promise  Lio/netty/channel/ChannelPromise;
            1    5     4  pendingWrites  Lio/netty/channel/PendingWriteQueue;
    MethodParameters:
         Name  Flags
      ctx      
      msg      
      promise  
}
SourceFile: "ProxyHandler.java"
NestMembers:
  io.netty.handler.proxy.ProxyHandler$1  io.netty.handler.proxy.ProxyHandler$2  io.netty.handler.proxy.ProxyHandler$LazyChannelPromise
InnerClasses:
  io.netty.handler.proxy.ProxyHandler$1
  io.netty.handler.proxy.ProxyHandler$2
  private final LazyChannelPromise = io.netty.handler.proxy.ProxyHandler$LazyChannelPromise of io.netty.handler.proxy.ProxyHandler