final class io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe extends io.netty.channel.AbstractChannel$AbstractUnsafe
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe
  super_class: io.netty.channel.AbstractChannel$AbstractUnsafe
{
  final io.netty.channel.rxtx.RxtxChannel this$0;
    descriptor: Lio/netty/channel/rxtx/RxtxChannel;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  private void <init>(io.netty.channel.rxtx.RxtxChannel);
    descriptor: (Lio/netty/channel/rxtx/RxtxChannel;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe this
         0: .line 152
            aload 0 /* this */
            aload 1
            putfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            aload 0 /* this */
            aload 1
            invokespecial io.netty.channel.AbstractChannel$AbstractUnsafe.<init>:(Lio/netty/channel/AbstractChannel;)V
            return
        end local 0 // io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;
    MethodParameters:
        Name  Flags
      this$0  final

  public void connect(java.net.SocketAddress, java.net.SocketAddress, io.netty.channel.ChannelPromise);
    descriptor: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lio/netty/channel/ChannelPromise;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=6, args_size=4
        start local 0 // io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe this
        start local 1 // java.net.SocketAddress remoteAddress
        start local 2 // java.net.SocketAddress localAddress
        start local 3 // io.netty.channel.ChannelPromise promise
         0: .line 157
            aload 3 /* promise */
            invokeinterface io.netty.channel.ChannelPromise.setUncancellable:()Z
            ifeq 1
            aload 0 /* this */
            aload 3 /* promise */
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.ensureOpen:(Lio/netty/channel/ChannelPromise;)Z
            ifne 2
         1: .line 158
      StackMap locals:
      StackMap stack:
            return
         2: .line 162
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            invokevirtual io.netty.channel.rxtx.RxtxChannel.isActive:()Z
            istore 4 /* wasActive */
        start local 4 // boolean wasActive
         3: .line 163
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            aload 1 /* remoteAddress */
            aload 2 /* localAddress */
            invokevirtual io.netty.channel.rxtx.RxtxChannel.doConnect:(Ljava/net/SocketAddress;Ljava/net/SocketAddress;)V
         4: .line 165
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            invokevirtual io.netty.channel.rxtx.RxtxChannel.config:()Lio/netty/channel/rxtx/RxtxChannelConfig;
            getstatic io.netty.channel.rxtx.RxtxChannelOption.WAIT_TIME:Lio/netty/channel/ChannelOption;
            invokeinterface io.netty.channel.rxtx.RxtxChannelConfig.getOption:(Lio/netty/channel/ChannelOption;)Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            istore 5 /* waitTime */
        start local 5 // int waitTime
         5: .line 166
            iload 5 /* waitTime */
            ifle 10
         6: .line 167
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            invokevirtual io.netty.channel.rxtx.RxtxChannel.eventLoop:()Lio/netty/channel/EventLoop;
            new io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe$1
            dup
            aload 0 /* this */
            aload 3 /* promise */
            iload 4 /* wasActive */
            invokespecial io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe$1.<init>:(Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;Lio/netty/channel/ChannelPromise;Z)V
         7: .line 181
            iload 5 /* waitTime */
            i2l
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
         8: .line 167
            invokeinterface io.netty.channel.EventLoop.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/ScheduledFuture;
            pop
         9: .line 182
            goto 18
        10: .line 183
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            invokevirtual io.netty.channel.rxtx.RxtxChannel.doInit:()V
        11: .line 184
            aload 0 /* this */
            aload 3 /* promise */
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.safeSetSuccess:(Lio/netty/channel/ChannelPromise;)V
        12: .line 185
            iload 4 /* wasActive */
            ifne 18
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            invokevirtual io.netty.channel.rxtx.RxtxChannel.isActive:()Z
            ifeq 18
        13: .line 186
            aload 0 /* this */
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            invokevirtual io.netty.channel.rxtx.RxtxChannel.pipeline:()Lio/netty/channel/ChannelPipeline;
            invokeinterface io.netty.channel.ChannelPipeline.fireChannelActive:()Lio/netty/channel/ChannelPipeline;
            pop
        end local 5 // int waitTime
        end local 4 // boolean wasActive
        14: .line 189
            goto 18
      StackMap locals: io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe java.net.SocketAddress java.net.SocketAddress io.netty.channel.ChannelPromise
      StackMap stack: java.lang.Throwable
        15: astore 4 /* t */
        start local 4 // java.lang.Throwable t
        16: .line 190
            aload 0 /* this */
            aload 3 /* promise */
            aload 4 /* t */
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.safeSetFailure:(Lio/netty/channel/ChannelPromise;Ljava/lang/Throwable;)V
        17: .line 191
            aload 0 /* this */
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.closeIfClosed:()V
        end local 4 // java.lang.Throwable t
        18: .line 193
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.netty.channel.ChannelPromise promise
        end local 2 // java.net.SocketAddress localAddress
        end local 1 // java.net.SocketAddress remoteAddress
        end local 0 // io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   19     0           this  Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;
            0   19     1  remoteAddress  Ljava/net/SocketAddress;
            0   19     2   localAddress  Ljava/net/SocketAddress;
            0   19     3        promise  Lio/netty/channel/ChannelPromise;
            3   14     4      wasActive  Z
            5   14     5       waitTime  I
           16   18     4              t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           2    14      15  Class java.lang.Throwable
    MethodParameters:
               Name  Flags
      remoteAddress  final
      localAddress   final
      promise        final

  static void access$0(io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;Lio/netty/channel/ChannelPromise;)V
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.safeSetSuccess:(Lio/netty/channel/ChannelPromise;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static void access$1(io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe, io.netty.channel.ChannelPromise, java.lang.Throwable);
    descriptor: (Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;Lio/netty/channel/ChannelPromise;Ljava/lang/Throwable;)V
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            aload 2
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.safeSetFailure:(Lio/netty/channel/ChannelPromise;Ljava/lang/Throwable;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static void access$2(io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe);
    descriptor: (Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;)V
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.closeIfClosed:()V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static io.netty.channel.rxtx.RxtxChannel access$3(io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe);
    descriptor: (Lio/netty/channel/rxtx/RxtxChannel$RxtxUnsafe;)Lio/netty/channel/rxtx/RxtxChannel;
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 152
            aload 0
            getfield io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe.this$0:Lio/netty/channel/rxtx/RxtxChannel;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "RxtxChannel.java"
NestHost: io.netty.channel.rxtx.RxtxChannel
InnerClasses:
  protected abstract AbstractUnsafe = io.netty.channel.AbstractChannel$AbstractUnsafe of io.netty.channel.AbstractChannel
  private final RxtxUnsafe = io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe of io.netty.channel.rxtx.RxtxChannel
  io.netty.channel.rxtx.RxtxChannel$RxtxUnsafe$1