http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-core: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.core.net.impl.NetSocketImpl extends io.vertx.core.net.impl.ConnectionBase implements io.vertx.core.net.impl.NetSocketInternal
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.core.net.impl.NetSocketImpl
  super_class: io.vertx.core.net.impl.ConnectionBase
{
  private static final io.vertx.core.Handler<java.lang.Object> NULL_MSG_HANDLER;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Lio/vertx/core/Handler<Ljava/lang/Object;>;

  private static final io.vertx.core.impl.logging.Logger log;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.lang.String writeHandlerID;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.net.impl.SSLHelper helper;
    descriptor: Lio/vertx/core/net/impl/SSLHelper;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.net.SocketAddress remoteAddress;
    descriptor: Lio/vertx/core/net/SocketAddress;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.spi.metrics.TCPMetrics metrics;
    descriptor: Lio/vertx/core/spi/metrics/TCPMetrics;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.streams.impl.InboundBuffer<java.lang.Object> pending;
    descriptor: Lio/vertx/core/streams/impl/InboundBuffer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lio/vertx/core/streams/impl/InboundBuffer<Ljava/lang/Object;>;

  private io.vertx.core.Handler<java.lang.Void> endHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;

  private io.vertx.core.Handler<java.lang.Void> drainHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;

  private io.vertx.core.eventbus.MessageConsumer registration;
    descriptor: Lio/vertx/core/eventbus/MessageConsumer;
    flags: (0x0002) ACC_PRIVATE

  private io.vertx.core.Handler<java.lang.Object> messageHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Object;>;

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 55
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$0(Ljava/lang/Object;)V (6)
                  (Ljava/lang/Object;)V
            putstatic io.vertx.core.net.impl.NetSocketImpl.NULL_MSG_HANDLER:Lio/vertx/core/Handler;
         1: .line 62
            ldc Lio/vertx/core/net/impl/NetSocketImpl;
            invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
            putstatic io.vertx.core.net.impl.NetSocketImpl.log:Lio/vertx/core/impl/logging/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(io.vertx.core.impl.ContextInternal, io.netty.channel.ChannelHandlerContext, io.vertx.core.net.impl.SSLHelper, io.vertx.core.spi.metrics.TCPMetrics);
    descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=5
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.impl.ContextInternal context
        start local 2 // io.netty.channel.ChannelHandlerContext channel
        start local 3 // io.vertx.core.net.impl.SSLHelper helper
        start local 4 // io.vertx.core.spi.metrics.TCPMetrics metrics
         0: .line 75
            aload 0 /* this */
            aload 1 /* context */
            aload 2 /* channel */
            aconst_null
            aload 3 /* helper */
            aload 4 /* metrics */
            invokespecial io.vertx.core.net.impl.NetSocketImpl.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
         1: .line 76
            return
        end local 4 // io.vertx.core.spi.metrics.TCPMetrics metrics
        end local 3 // io.vertx.core.net.impl.SSLHelper helper
        end local 2 // io.netty.channel.ChannelHandlerContext channel
        end local 1 // io.vertx.core.impl.ContextInternal context
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  context  Lio/vertx/core/impl/ContextInternal;
            0    2     2  channel  Lio/netty/channel/ChannelHandlerContext;
            0    2     3   helper  Lio/vertx/core/net/impl/SSLHelper;
            0    2     4  metrics  Lio/vertx/core/spi/metrics/TCPMetrics;
    MethodParameters:
         Name  Flags
      context  
      channel  
      helper   
      metrics  

  public void <init>(io.vertx.core.impl.ContextInternal, io.netty.channel.ChannelHandlerContext, io.vertx.core.net.SocketAddress, io.vertx.core.net.impl.SSLHelper, io.vertx.core.spi.metrics.TCPMetrics);
    descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=6
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.impl.ContextInternal context
        start local 2 // io.netty.channel.ChannelHandlerContext channel
        start local 3 // io.vertx.core.net.SocketAddress remoteAddress
        start local 4 // io.vertx.core.net.impl.SSLHelper helper
        start local 5 // io.vertx.core.spi.metrics.TCPMetrics metrics
         0: .line 79
            aload 0 /* this */
            aload 1 /* context */
            aload 2 /* channel */
            invokespecial io.vertx.core.net.impl.ConnectionBase.<init>:(Lio/vertx/core/impl/ContextInternal;Lio/netty/channel/ChannelHandlerContext;)V
         1: .line 80
            aload 0 /* this */
            aload 4 /* helper */
            putfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
         2: .line 81
            aload 0 /* this */
            new java.lang.StringBuilder
            dup
            ldc "__vertx.net."
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            putfield io.vertx.core.net.impl.NetSocketImpl.writeHandlerID:Ljava/lang/String;
         3: .line 82
            aload 0 /* this */
            aload 3 /* remoteAddress */
            putfield io.vertx.core.net.impl.NetSocketImpl.remoteAddress:Lio/vertx/core/net/SocketAddress;
         4: .line 83
            aload 0 /* this */
            aload 5 /* metrics */
            putfield io.vertx.core.net.impl.NetSocketImpl.metrics:Lio/vertx/core/spi/metrics/TCPMetrics;
         5: .line 84
            aload 0 /* this */
            getstatic io.vertx.core.net.impl.NetSocketImpl.NULL_MSG_HANDLER:Lio/vertx/core/Handler;
            putfield io.vertx.core.net.impl.NetSocketImpl.messageHandler:Lio/vertx/core/Handler;
         6: .line 85
            aload 0 /* this */
            new io.vertx.core.streams.impl.InboundBuffer
            dup
            aload 1 /* context */
            invokespecial io.vertx.core.streams.impl.InboundBuffer.<init>:(Lio/vertx/core/Context;)V
            putfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
         7: .line 86
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$1(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/impl/InboundBuffer;
            pop
         8: .line 87
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 1 /* context */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic handle(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/impl/ContextInternal.reportException(Ljava/lang/Throwable;)V (9 itf)
                  (Ljava/lang/Throwable;)V
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/impl/InboundBuffer;
            pop
         9: .line 88
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$3(Ljava/lang/Object;)V (7)
                  (Ljava/lang/Object;)V
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/impl/InboundBuffer;
            pop
        10: .line 101
            return
        end local 5 // io.vertx.core.spi.metrics.TCPMetrics metrics
        end local 4 // io.vertx.core.net.impl.SSLHelper helper
        end local 3 // io.vertx.core.net.SocketAddress remoteAddress
        end local 2 // io.netty.channel.ChannelHandlerContext channel
        end local 1 // io.vertx.core.impl.ContextInternal context
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   11     0           this  Lio/vertx/core/net/impl/NetSocketImpl;
            0   11     1        context  Lio/vertx/core/impl/ContextInternal;
            0   11     2        channel  Lio/netty/channel/ChannelHandlerContext;
            0   11     3  remoteAddress  Lio/vertx/core/net/SocketAddress;
            0   11     4         helper  Lio/vertx/core/net/impl/SSLHelper;
            0   11     5        metrics  Lio/vertx/core/spi/metrics/TCPMetrics;
    MethodParameters:
               Name  Flags
      context        
      channel        
      remoteAddress  
      helper         
      metrics        

  synchronized void registerEventBusHandler();
    descriptor: ()V
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 104
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$4(Lio/vertx/core/eventbus/Message;)V (7)
                  (Lio/vertx/core/eventbus/Message;)V
            astore 1 /* writeHandler */
        start local 1 // io.vertx.core.Handler writeHandler
         1: .line 105
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.eventBus:()Lio/vertx/core/eventbus/EventBus;
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.writeHandlerID:Ljava/lang/String;
            invokeinterface io.vertx.core.eventbus.EventBus.localConsumer:(Ljava/lang/String;)Lio/vertx/core/eventbus/MessageConsumer;
            aload 1 /* writeHandler */
            invokeinterface io.vertx.core.eventbus.MessageConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/MessageConsumer;
            putfield io.vertx.core.net.impl.NetSocketImpl.registration:Lio/vertx/core/eventbus/MessageConsumer;
         2: .line 106
            return
        end local 1 // io.vertx.core.Handler writeHandler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/vertx/core/net/impl/NetSocketImpl;
            1    3     1  writeHandler  Lio/vertx/core/Handler<Lio/vertx/core/eventbus/Message<Lio/vertx/core/buffer/Buffer;>;>;

  public io.vertx.core.spi.metrics.TCPMetrics metrics();
    descriptor: ()Lio/vertx/core/spi/metrics/TCPMetrics;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 110
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.metrics:Lio/vertx/core/spi/metrics/TCPMetrics;
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  public java.lang.String writeHandlerID();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 115
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.writeHandlerID:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  public synchronized io.vertx.core.Future<java.lang.Void> writeMessage();
    descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object message
         0: .line 120
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 121
            aload 0 /* this */
            aload 1 /* message */
            aload 2 /* promise */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeMessage:(Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
            pop
         2: .line 122
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.lang.Object message
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1  message  Ljava/lang/Object;
            1    3     2  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/lang/Object;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
         Name  Flags
      message  

  public io.vertx.core.net.impl.NetSocketInternal writeMessage(, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object message
        start local 2 // io.vertx.core.Handler handler
         0: .line 127
            aload 0 /* this */
            aload 1 /* message */
            aload 2 /* handler */
            ifnonnull 1
            aconst_null
            goto 2
      StackMap locals: io.vertx.core.net.impl.NetSocketImpl java.lang.Object io.vertx.core.Handler
      StackMap stack: io.vertx.core.net.impl.NetSocketImpl java.lang.Object
         1: aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            aload 2 /* handler */
            invokeinterface io.vertx.core.impl.ContextInternal.promise:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
      StackMap locals: io.vertx.core.net.impl.NetSocketImpl java.lang.Object io.vertx.core.Handler
      StackMap stack: io.vertx.core.net.impl.NetSocketImpl java.lang.Object io.vertx.core.impl.future.PromiseInternal
         2: invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeToChannel:(Ljava/lang/Object;Lio/netty/util/concurrent/FutureListener;)V
         3: .line 128
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.Object message
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    4     1  message  Ljava/lang/Object;
            0    4     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/impl/NetSocketInternal;
    MethodParameters:
         Name  Flags
      message  
      handler  

  protected void reportsBytesWritten(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object msg
         0: .line 133
            aload 1 /* msg */
            instanceof io.netty.buffer.ByteBuf
            ifeq 2
         1: .line 134
            aload 0 /* this */
            aload 1 /* msg */
            checkcast io.netty.buffer.ByteBuf
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.reportBytesWritten:(J)V
         2: .line 136
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object msg
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1   msg  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      msg   

  protected void reportBytesRead(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object msg
         0: .line 140
            aload 1 /* msg */
            instanceof io.netty.buffer.ByteBuf
            ifeq 2
         1: .line 141
            aload 0 /* this */
            aload 1 /* msg */
            checkcast io.netty.buffer.ByteBuf
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.reportBytesRead:(J)V
         2: .line 143
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object msg
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1   msg  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      msg   

  public io.vertx.core.Future<java.lang.Void> write(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.buffer.Buffer data
         0: .line 147
            aload 0 /* this */
            aload 1 /* data */
            invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.buffer.Buffer data
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1  data  Lio/vertx/core/buffer/Buffer;
    Signature: (Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      data  

  public void write(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String str
        start local 2 // io.vertx.core.Handler handler
         0: .line 152
            aload 0 /* this */
            aload 1 /* str */
            getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
            invokestatic io.netty.buffer.Unpooled.copiedBuffer:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
            aload 2 /* handler */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
         1: .line 153
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.String str
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1      str  Ljava/lang/String;
            0    2     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      str      
      handler  

  public io.vertx.core.Future<java.lang.Void> write(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String str
         0: .line 157
            aload 0 /* this */
            aload 1 /* str */
            getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
            invokestatic io.netty.buffer.Unpooled.copiedBuffer:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 1 // java.lang.String str
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1   str  Ljava/lang/String;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      str   

  public io.vertx.core.Future<java.lang.Void> write(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String str
        start local 2 // java.lang.String enc
         0: .line 162
            aload 0 /* this */
            aload 1 /* str */
            aload 2 /* enc */
            invokestatic java.nio.charset.Charset.forName:(Ljava/lang/String;)Ljava/nio/charset/Charset;
            invokestatic io.netty.buffer.Unpooled.copiedBuffer:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 2 // java.lang.String enc
        end local 1 // java.lang.String str
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1   str  Ljava/lang/String;
            0    1     2   enc  Ljava/lang/String;
    Signature: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      str   
      enc   

  public void write(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String str
        start local 2 // java.lang.String enc
        start local 3 // io.vertx.core.Handler handler
         0: .line 167
            aload 2 /* enc */
            ifnull 1
            aload 2 /* enc */
            invokestatic java.nio.charset.Charset.forName:(Ljava/lang/String;)Ljava/nio/charset/Charset;
            goto 2
      StackMap locals:
      StackMap stack:
         1: getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
      StackMap locals:
      StackMap stack: java.nio.charset.Charset
         2: astore 4 /* cs */
        start local 4 // java.nio.charset.Charset cs
         3: .line 168
            aload 0 /* this */
            aload 1 /* str */
            aload 4 /* cs */
            invokestatic io.netty.buffer.Unpooled.copiedBuffer:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
            aload 3 /* handler */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
         4: .line 169
            return
        end local 4 // java.nio.charset.Charset cs
        end local 3 // io.vertx.core.Handler handler
        end local 2 // java.lang.String enc
        end local 1 // java.lang.String str
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    5     1      str  Ljava/lang/String;
            0    5     2      enc  Ljava/lang/String;
            0    5     3  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            3    5     4       cs  Ljava/nio/charset/Charset;
    Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      str      
      enc      
      handler  

  public void write(io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.buffer.Buffer message
        start local 2 // io.vertx.core.Handler handler
         0: .line 173
            aload 0 /* this */
            aload 1 /* message */
            invokeinterface io.vertx.core.buffer.Buffer.getByteBuf:()Lio/netty/buffer/ByteBuf;
            aload 2 /* handler */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
         1: .line 174
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // io.vertx.core.buffer.Buffer message
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  message  Lio/vertx/core/buffer/Buffer;
            0    2     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      message  
      handler  

  private void write(io.netty.buffer.ByteBuf, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.netty.buffer.ByteBuf buff
        start local 2 // io.vertx.core.Handler handler
         0: .line 177
            aload 0 /* this */
            aload 1 /* buff */
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.reportBytesWritten:(J)V
         1: .line 178
            aload 0 /* this */
            aload 1 /* buff */
            aload 2 /* handler */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeMessage:(Ljava/lang/Object;Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
            pop
         2: .line 179
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // io.netty.buffer.ByteBuf buff
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1     buff  Lio/netty/buffer/ByteBuf;
            0    3     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/netty/buffer/ByteBuf;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      buff     
      handler  

  public synchronized io.vertx.core.net.NetSocket handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler dataHandler
         0: .line 183
            aload 1 /* dataHandler */
            ifnull 3
         1: .line 184
            aload 0 /* this */
            new io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler
            dup
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
            aload 1 /* dataHandler */
            invokespecial io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler.<init>:(Lio/vertx/core/net/impl/NetSocketImpl;Lio/netty/buffer/ByteBufAllocator;Lio/vertx/core/Handler;)V
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
            pop
         2: .line 185
            goto 4
         3: .line 186
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
            pop
         4: .line 188
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler dataHandler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0         this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    5     1  dataHandler  Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/net/NetSocket;
    MethodParameters:
             Name  Flags
      dataHandler  

  private synchronized io.vertx.core.Handler<java.lang.Object> messageHandler();
    descriptor: ()Lio/vertx/core/Handler;
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 192
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.messageHandler:Lio/vertx/core/Handler;
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
    Signature: ()Lio/vertx/core/Handler<Ljava/lang/Object;>;

  public synchronized io.vertx.core.net.impl.NetSocketInternal messageHandler(io.vertx.core.Handler<java.lang.Object>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 197
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.net.impl.NetSocketImpl.messageHandler:Lio/vertx/core/Handler;
         1: .line 198
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/lang/Object;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Object;>;)Lio/vertx/core/net/impl/NetSocketInternal;
    MethodParameters:
         Name  Flags
      handler  

  public synchronized io.vertx.core.net.NetSocket pause();
    descriptor: ()Lio/vertx/core/net/NetSocket;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 203
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.pause:()Lio/vertx/core/streams/impl/InboundBuffer;
            pop
         1: .line 204
            aload 0 /* this */
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  public io.vertx.core.net.NetSocket fetch(long);
    descriptor: (J)Lio/vertx/core/net/NetSocket;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // long amount
         0: .line 209
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            lload 1 /* amount */
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.fetch:(J)Z
            pop
         1: .line 210
            aload 0 /* this */
            areturn
        end local 1 // long amount
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  amount  J
    MethodParameters:
        Name  Flags
      amount  

  public synchronized io.vertx.core.net.NetSocket resume();
    descriptor: ()Lio/vertx/core/net/NetSocket;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 215
            aload 0 /* this */
            ldc 9223372036854775807
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.fetch:(J)Lio/vertx/core/net/NetSocket;
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  public io.vertx.core.net.NetSocket setWriteQueueMaxSize(int);
    descriptor: (I)Lio/vertx/core/net/NetSocket;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // int maxSize
         0: .line 220
            aload 0 /* this */
            iload 1 /* maxSize */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.doSetWriteQueueMaxSize:(I)V
         1: .line 221
            aload 0 /* this */
            areturn
        end local 1 // int maxSize
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  maxSize  I
    MethodParameters:
         Name  Flags
      maxSize  

  public boolean writeQueueFull();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 226
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.isNotWritable:()Z
            ireturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  private synchronized io.vertx.core.Handler<java.lang.Void> endHandler();
    descriptor: ()Lio/vertx/core/Handler;
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 230
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.endHandler:Lio/vertx/core/Handler;
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
    Signature: ()Lio/vertx/core/Handler<Ljava/lang/Void;>;

  public synchronized io.vertx.core.net.NetSocket endHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler endHandler
         0: .line 235
            aload 0 /* this */
            aload 1 /* endHandler */
            putfield io.vertx.core.net.impl.NetSocketImpl.endHandler:Lio/vertx/core/Handler;
         1: .line 236
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler endHandler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  endHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/NetSocket;
    MethodParameters:
            Name  Flags
      endHandler  

  public synchronized io.vertx.core.net.NetSocket drainHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler drainHandler
         0: .line 241
            aload 0 /* this */
            aload 1 /* drainHandler */
            putfield io.vertx.core.net.impl.NetSocketImpl.drainHandler:Lio/vertx/core/Handler;
         1: .line 242
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$5(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.impl.VertxInternal.runOnContext:(Lio/vertx/core/Handler;)V
         2: .line 243
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler drainHandler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1  drainHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/NetSocket;
    MethodParameters:
              Name  Flags
      drainHandler  

  public io.vertx.core.Future<java.lang.Void> sendFile(java.lang.String, long, long);
    descriptor: (Ljava/lang/String;JJ)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=7, args_size=4
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String filename
        start local 2 // long offset
        start local 4 // long length
         0: .line 248
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
            astore 6 /* promise */
        start local 6 // io.vertx.core.Promise promise
         1: .line 249
            aload 0 /* this */
            aload 1 /* filename */
            lload 2 /* offset */
            lload 4 /* length */
            aload 6 /* promise */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.sendFile:(Ljava/lang/String;JJLio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
         2: .line 250
            aload 6 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 6 // io.vertx.core.Promise promise
        end local 4 // long length
        end local 2 // long offset
        end local 1 // java.lang.String filename
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1  filename  Ljava/lang/String;
            0    3     2    offset  J
            0    3     4    length  J
            1    3     6   promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/lang/String;JJ)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
          Name  Flags
      filename  
      offset    
      length    

  public io.vertx.core.net.NetSocket sendFile(java.lang.String, long, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/lang/String;JJLio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=10, locals=10, args_size=5
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String filename
        start local 2 // long offset
        start local 4 // long length
        start local 6 // io.vertx.core.Handler resultHandler
         0: .line 255
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 1 /* filename */
            invokeinterface io.vertx.core.impl.VertxInternal.resolveFile:(Ljava/lang/String;)Ljava/io/File;
            astore 7 /* f */
        start local 7 // java.io.File f
         1: .line 256
            aload 7 /* f */
            invokevirtual java.io.File.isDirectory:()Z
            ifeq 3
         2: .line 257
            new java.lang.IllegalArgumentException
            dup
            ldc "filename must point to a file and not to a directory"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 259
      StackMap locals: java.io.File
      StackMap stack:
            aconst_null
            astore 8 /* raf */
        start local 8 // java.io.RandomAccessFile raf
         4: .line 261
            new java.io.RandomAccessFile
            dup
            aload 7 /* f */
            ldc "r"
            invokespecial java.io.RandomAccessFile.<init>:(Ljava/io/File;Ljava/lang/String;)V
            astore 8 /* raf */
         5: .line 262
            aload 0 /* this */
            aload 8 /* raf */
            lload 2 /* offset */
            aload 7 /* f */
            invokevirtual java.io.File.length:()J
            invokestatic java.lang.Math.min:(JJ)J
            lload 4 /* length */
            aload 7 /* f */
            invokevirtual java.io.File.length:()J
            lload 2 /* offset */
            lsub
            invokestatic java.lang.Math.min:(JJ)J
            invokespecial io.vertx.core.net.impl.ConnectionBase.sendFile:(Ljava/io/RandomAccessFile;JJ)Lio/netty/channel/ChannelFuture;
            astore 9 /* future */
        start local 9 // io.netty.channel.ChannelFuture future
         6: .line 263
            aload 6 /* resultHandler */
            ifnull 18
         7: .line 264
            aload 9 /* future */
            aload 0 /* this */
            aload 9 /* future */
            aload 6 /* resultHandler */
            invokedynamic operationComplete(Lio/vertx/core/net/impl/NetSocketImpl;Lio/netty/channel/ChannelFuture;Lio/vertx/core/Handler;)Lio/netty/util/concurrent/GenericFutureListener;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Lio/netty/util/concurrent/Future;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$6(Lio/netty/channel/ChannelFuture;Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V (7)
                  (Lio/netty/util/concurrent/Future;)V
            invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
            pop
        end local 9 // io.netty.channel.ChannelFuture future
         8: .line 274
            goto 18
      StackMap locals: io.vertx.core.net.impl.NetSocketImpl java.lang.String long long io.vertx.core.Handler java.io.File java.io.RandomAccessFile
      StackMap stack: java.io.IOException
         9: astore 9 /* e */
        start local 9 // java.io.IOException e
        10: .line 276
            aload 8 /* raf */
            ifnull 14
        11: .line 277
            aload 8 /* raf */
            invokevirtual java.io.RandomAccessFile.close:()V
        12: .line 279
            goto 14
      StackMap locals: io.vertx.core.net.impl.NetSocketImpl java.lang.String long long io.vertx.core.Handler java.io.File java.io.RandomAccessFile java.io.IOException
      StackMap stack: java.io.IOException
        13: pop
        14: .line 281
      StackMap locals:
      StackMap stack:
            aload 6 /* resultHandler */
            ifnull 17
        15: .line 282
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 6 /* resultHandler */
            aload 9 /* e */
            invokedynamic handle(Lio/vertx/core/Handler;Ljava/io/IOException;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$8(Lio/vertx/core/Handler;Ljava/io/IOException;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.impl.VertxInternal.runOnContext:(Lio/vertx/core/Handler;)V
        16: .line 283
            goto 18
        17: .line 284
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.core.net.impl.NetSocketImpl.log:Lio/vertx/core/impl/logging/Logger;
            ldc "Failed to send file"
            aload 9 /* e */
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        end local 9 // java.io.IOException e
        18: .line 287
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 8 // java.io.RandomAccessFile raf
        end local 7 // java.io.File f
        end local 6 // io.vertx.core.Handler resultHandler
        end local 4 // long length
        end local 2 // long offset
        end local 1 // java.lang.String filename
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   19     0           this  Lio/vertx/core/net/impl/NetSocketImpl;
            0   19     1       filename  Ljava/lang/String;
            0   19     2         offset  J
            0   19     4         length  J
            0   19     6  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1   19     7              f  Ljava/io/File;
            4   19     8            raf  Ljava/io/RandomAccessFile;
            6    8     9         future  Lio/netty/channel/ChannelFuture;
           10   18     9              e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           4     8       9  Class java.io.IOException
          10    12      13  Class java.io.IOException
    Signature: (Ljava/lang/String;JJLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
    MethodParameters:
               Name  Flags
      filename       
      offset         
      length         
      resultHandler  final

  public io.vertx.core.net.impl.NetSocketImpl exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 291
            aload 0 /* this */
            aload 1 /* handler */
            invokespecial io.vertx.core.net.impl.ConnectionBase.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
            checkcast io.vertx.core.net.impl.NetSocketImpl
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1  handler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/core/net/impl/NetSocketImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.net.impl.NetSocketImpl closeHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 296
            aload 0 /* this */
            aload 1 /* handler */
            invokespecial io.vertx.core.net.impl.ConnectionBase.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
            checkcast io.vertx.core.net.impl.NetSocketImpl
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/net/impl/NetSocketImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.lang.Void> upgradeToSsl();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 301
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 302
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.upgradeToSsl:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
         2: .line 303
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public io.vertx.core.Future<java.lang.Void> upgradeToSsl(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String serverName
         0: .line 308
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 309
            aload 0 /* this */
            aload 1 /* serverName */
            aload 2 /* promise */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.upgradeToSsl:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
         2: .line 310
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.lang.String serverName
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     1  serverName  Ljava/lang/String;
            1    3     2     promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
            Name  Flags
      serverName  

  public io.vertx.core.net.NetSocket upgradeToSsl(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 315
            aload 0 /* this */
            aconst_null
            aload 1 /* handler */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.upgradeToSsl:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.net.NetSocket upgradeToSsl(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.String serverName
        start local 2 // io.vertx.core.Handler handler
         0: .line 320
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "ssl"
            invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
            checkcast io.netty.channel.ChannelOutboundHandler
            astore 3 /* sslHandler */
        start local 3 // io.netty.channel.ChannelOutboundHandler sslHandler
         1: .line 321
            aload 3 /* sslHandler */
            ifnonnull 15
         2: .line 322
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.newPromise:()Lio/netty/channel/ChannelPromise;
            astore 4 /* p */
        start local 4 // io.netty.channel.ChannelPromise p
         3: .line 323
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "handshaker"
            new io.vertx.core.net.impl.SslHandshakeCompletionHandler
            dup
            aload 4 /* p */
            invokespecial io.vertx.core.net.impl.SslHandshakeCompletionHandler.<init>:(Lio/netty/util/concurrent/Promise;)V
            invokeinterface io.netty.channel.ChannelPipeline.addFirst:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
         4: .line 324
            aload 4 /* p */
            aload 0 /* this */
            aload 2 /* handler */
            invokedynamic operationComplete(Lio/vertx/core/net/impl/NetSocketImpl;Lio/vertx/core/Handler;)Lio/netty/util/concurrent/GenericFutureListener;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Lio/netty/util/concurrent/Future;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$9(Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V (7)
                  (Lio/netty/util/concurrent/Future;)V
            invokeinterface io.netty.channel.ChannelPromise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelPromise;
            pop
         5: .line 335
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.remoteAddress:Lio/vertx/core/net/SocketAddress;
            ifnull 9
         6: .line 336
            new io.netty.handler.ssl.SslHandler
            dup
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.remoteAddress:Lio/vertx/core/net/SocketAddress;
            aload 1 /* serverName */
            invokevirtual io.vertx.core.net.impl.SSLHelper.createEngine:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/net/SocketAddress;Ljava/lang/String;)Ljavax/net/ssl/SSLEngine;
            invokespecial io.netty.handler.ssl.SslHandler.<init>:(Ljavax/net/ssl/SSLEngine;)V
            astore 3 /* sslHandler */
         7: .line 337
            aload 3 /* sslHandler */
            checkcast io.netty.handler.ssl.SslHandler
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeout:()J
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeoutUnit:()Ljava/util/concurrent/TimeUnit;
            invokevirtual io.netty.handler.ssl.SslHandler.setHandshakeTimeout:(JLjava/util/concurrent/TimeUnit;)V
         8: .line 338
            goto 14
         9: .line 339
      StackMap locals: io.netty.channel.ChannelOutboundHandler io.netty.channel.ChannelPromise
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            invokevirtual io.vertx.core.net.impl.SSLHelper.isSNI:()Z
            ifeq 12
        10: .line 340
            new io.netty.handler.ssl.SniHandler
            dup
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokevirtual io.vertx.core.net.impl.SSLHelper.serverNameMapper:(Lio/vertx/core/impl/VertxInternal;)Lio/netty/util/Mapping;
            invokespecial io.netty.handler.ssl.SniHandler.<init>:(Lio/netty/util/Mapping;)V
            astore 3 /* sslHandler */
        11: .line 341
            goto 14
        12: .line 342
      StackMap locals:
      StackMap stack:
            new io.netty.handler.ssl.SslHandler
            dup
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokevirtual io.vertx.core.net.impl.SSLHelper.createEngine:(Lio/vertx/core/impl/VertxInternal;)Ljavax/net/ssl/SSLEngine;
            invokespecial io.netty.handler.ssl.SslHandler.<init>:(Ljavax/net/ssl/SSLEngine;)V
            astore 3 /* sslHandler */
        13: .line 343
            aload 3 /* sslHandler */
            checkcast io.netty.handler.ssl.SslHandler
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeout:()J
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.helper:Lio/vertx/core/net/impl/SSLHelper;
            invokevirtual io.vertx.core.net.impl.SSLHelper.getSslHandshakeTimeoutUnit:()Ljava/util/concurrent/TimeUnit;
            invokevirtual io.netty.handler.ssl.SslHandler.setHandshakeTimeout:(JLjava/util/concurrent/TimeUnit;)V
        14: .line 346
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "ssl"
            aload 3 /* sslHandler */
            invokeinterface io.netty.channel.ChannelPipeline.addFirst:(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
        end local 4 // io.netty.channel.ChannelPromise p
        15: .line 348
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 3 // io.netty.channel.ChannelOutboundHandler sslHandler
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.String serverName
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   16     0        this  Lio/vertx/core/net/impl/NetSocketImpl;
            0   16     1  serverName  Ljava/lang/String;
            0   16     2     handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1   16     3  sslHandler  Lio/netty/channel/ChannelOutboundHandler;
            3   15     4           p  Lio/netty/channel/ChannelPromise;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/core/net/NetSocket;
    MethodParameters:
            Name  Flags
      serverName  
      handler     

  protected void handleInterestedOpsChanged();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 353
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            aconst_null
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$10(Ljava/lang/Object;)V (7)
                  (Ljava/lang/Object;)V
            invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
         1: .line 354
            return
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 358
            aload 0 /* this */
            aload 1 /* handler */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.close:(Lio/vertx/core/Handler;)V
         1: .line 359
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.lang.Void> end();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 363
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.close:()Lio/vertx/core/Future;
            areturn
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  protected void handleClosed();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 369
            aload 0 /* this */
            dup
            astore 2
            monitorenter
         1: .line 370
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.registration:Lio/vertx/core/eventbus/MessageConsumer;
            astore 1 /* consumer */
        start local 1 // io.vertx.core.eventbus.MessageConsumer consumer
         2: .line 371
            aload 0 /* this */
            aconst_null
            putfield io.vertx.core.net.impl.NetSocketImpl.registration:Lio/vertx/core/eventbus/MessageConsumer;
         3: .line 369
            aload 2
            monitorexit
         4: goto 7
        end local 1 // io.vertx.core.eventbus.MessageConsumer consumer
      StackMap locals: io.vertx.core.net.impl.NetSocketImpl top io.vertx.core.net.impl.NetSocketImpl
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
        start local 1 // io.vertx.core.eventbus.MessageConsumer consumer
         7: .line 373
      StackMap locals: io.vertx.core.net.impl.NetSocketImpl io.vertx.core.eventbus.MessageConsumer
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            getstatic io.vertx.core.streams.impl.InboundBuffer.END_SENTINEL:Ljava/lang/Object;
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic handle(Lio/vertx/core/streams/impl/InboundBuffer;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/streams/impl/InboundBuffer.write(Ljava/lang/Object;)Z (5)
                  (Ljava/lang/Object;)V
            invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
         8: .line 374
            aload 0 /* this */
            invokespecial io.vertx.core.net.impl.ConnectionBase.handleClosed:()V
         9: .line 375
            aload 1 /* consumer */
            ifnull 11
        10: .line 376
            aload 1 /* consumer */
            invokeinterface io.vertx.core.eventbus.MessageConsumer.unregister:()Lio/vertx/core/Future;
            pop
        11: .line 378
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.eventbus.MessageConsumer consumer
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   12     0      this  Lio/vertx/core/net/impl/NetSocketImpl;
            2    5     1  consumer  Lio/vertx/core/eventbus/MessageConsumer;
            7   12     1  consumer  Lio/vertx/core/eventbus/MessageConsumer;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any

  public void handleMessage(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object msg
         0: .line 381
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            aload 1 /* msg */
            aload 0 /* this */
            aload 1 /* msg */
            invokedynamic handle(Lio/vertx/core/net/impl/NetSocketImpl;Ljava/lang/Object;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$12(Ljava/lang/Object;Ljava/lang/Object;)V (7)
                  (Ljava/lang/Object;)V
            invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
         1: .line 386
            return
        end local 1 // java.lang.Object msg
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    2     1   msg  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      msg   

  private synchronized void callDrainHandler();
    descriptor: ()V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
         0: .line 410
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.drainHandler:Lio/vertx/core/Handler;
            ifnull 3
         1: .line 411
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.writeQueueFull:()Z
            ifne 3
         2: .line 412
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.drainHandler:Lio/vertx/core/Handler;
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 415
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/core/net/impl/NetSocketImpl;

  public void write(java.lang.Object, io.vertx.core.Handler);
    descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            checkcast io.vertx.core.buffer.Buffer
            aload 2
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.Future write(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast io.vertx.core.buffer.Buffer
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.WriteStream setWriteQueueMaxSize(int);
    descriptor: (I)Lio/vertx/core/streams/WriteStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.setWriteQueueMaxSize:(I)Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.StreamBase exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/StreamBase;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.WriteStream exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.net.NetSocket exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.net.impl.ConnectionBase exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.net.NetSocket closeHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.net.impl.ConnectionBase closeHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/ConnectionBase;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream resume();
    descriptor: ()Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.resume:()Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.spi.metrics.NetworkMetrics metrics();
    descriptor: ()Lio/vertx/core/spi/metrics/NetworkMetrics;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.metrics:()Lio/vertx/core/spi/metrics/TCPMetrics;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast io.vertx.core.Handler
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream pause();
    descriptor: ()Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.pause:()Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.WriteStream drainHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream fetch(long);
    descriptor: (J)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
         0: .line 1
            aload 0
            lload 1
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.fetch:(J)Lio/vertx/core/net/NetSocket;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static void lambda$0(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // java.lang.Object event
         0: .line 56
            aload 0 /* event */
            instanceof io.netty.util.ReferenceCounted
            ifeq 3
         1: .line 57
            aload 0 /* event */
            checkcast io.netty.util.ReferenceCounted
            astore 1 /* refCounter */
        start local 1 // io.netty.util.ReferenceCounted refCounter
         2: .line 58
            aload 1 /* refCounter */
            invokeinterface io.netty.util.ReferenceCounted.release:()Z
            pop
        end local 1 // io.netty.util.ReferenceCounted refCounter
         3: .line 60
      StackMap locals:
      StackMap stack:
            return
        end local 0 // java.lang.Object event
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0       event  Ljava/lang/Object;
            2    3     1  refCounter  Lio/netty/util/ReferenceCounted;

  private void lambda$1(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Void v
         0: .line 86
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.doResume:()V
            return
        end local 1 // java.lang.Void v
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1     v  Ljava/lang/Void;

  private void lambda$3(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object obj
         0: .line 89
            aload 1 /* obj */
            getstatic io.vertx.core.streams.impl.InboundBuffer.END_SENTINEL:Ljava/lang/Object;
            if_acmpne 5
         1: .line 90
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.endHandler:()Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         2: .line 91
            aload 2 /* handler */
            ifnull 8
         3: .line 92
            aload 2 /* handler */
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 2 // io.vertx.core.Handler handler
         4: .line 94
            goto 8
         5: .line 95
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.messageHandler:()Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         6: .line 96
            aload 2 /* handler */
            ifnull 8
         7: .line 97
            aload 2 /* handler */
            aload 1 /* obj */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 2 // io.vertx.core.Handler handler
         8: .line 100
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object obj
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    9     1      obj  Ljava/lang/Object;
            2    4     2  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
            6    8     2  handler  Lio/vertx/core/Handler<Ljava/lang/Object;>;

  private void lambda$4(io.vertx.core.eventbus.Message);
    descriptor: (Lio/vertx/core/eventbus/Message;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // io.vertx.core.eventbus.Message msg
         0: .line 104
            aload 0 /* this */
            aload 1 /* msg */
            invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
            checkcast io.vertx.core.buffer.Buffer
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.write:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/Future;
            return
        end local 1 // io.vertx.core.eventbus.Message msg
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1   msg  Lio/vertx/core/eventbus/Message<Lio/vertx/core/buffer/Buffer;>;

  private void lambda$5(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Void v
         0: .line 242
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.callDrainHandler:()V
            return
        end local 1 // java.lang.Void v
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1     v  Ljava/lang/Void;

  private void lambda$6(io.netty.channel.ChannelFuture, io.vertx.core.Handler, io.netty.util.concurrent.Future);
    descriptor: (Lio/netty/channel/ChannelFuture;Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 3 // io.netty.util.concurrent.Future fut
         0: .line 266
            aload 1
            invokeinterface io.netty.channel.ChannelFuture.isSuccess:()Z
            ifeq 3
         1: .line 267
            invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
            astore 4 /* res */
        start local 4 // io.vertx.core.AsyncResult res
         2: .line 268
            goto 4
        end local 4 // io.vertx.core.AsyncResult res
         3: .line 269
      StackMap locals:
      StackMap stack:
            aload 1
            invokeinterface io.netty.channel.ChannelFuture.cause:()Ljava/lang/Throwable;
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            astore 4 /* res */
        start local 4 // io.vertx.core.AsyncResult res
         4: .line 271
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 2
            aload 4 /* res */
            invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/net/impl/NetSocketImpl.lambda$7(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.impl.VertxInternal.runOnContext:(Lio/vertx/core/Handler;)V
        end local 4 // io.vertx.core.AsyncResult res
         5: .line 272
            return
        end local 3 // io.netty.util.concurrent.Future fut
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    6     3   fut  Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
            2    3     4   res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
            4    5     4   res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$8(io.vertx.core.Handler, java.io.IOException, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Ljava/io/IOException;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Void v
         0: .line 282
            aload 0
            aload 1
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
            return
        end local 2 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     2     v  Ljava/lang/Void;

  private void lambda$9(io.vertx.core.Handler, io.netty.util.concurrent.Future);
    descriptor: (Lio/vertx/core/Handler;Lio/netty/util/concurrent/Future;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 2 // io.netty.util.concurrent.Future future
         0: .line 325
            aload 1
            ifnull 6
         1: .line 327
            aload 2 /* future */
            invokeinterface io.netty.util.concurrent.Future.isSuccess:()Z
            ifeq 4
         2: .line 328
            invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
            astore 3 /* res */
        start local 3 // io.vertx.core.AsyncResult res
         3: .line 329
            goto 5
        end local 3 // io.vertx.core.AsyncResult res
         4: .line 330
      StackMap locals:
      StackMap stack:
            aload 2 /* future */
            invokeinterface io.netty.util.concurrent.Future.cause:()Ljava/lang/Throwable;
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            astore 3 /* res */
        start local 3 // io.vertx.core.AsyncResult res
         5: .line 332
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.context:Lio/vertx/core/impl/ContextInternal;
            aload 3 /* res */
            aload 1
            invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
        end local 3 // io.vertx.core.AsyncResult res
         6: .line 334
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.netty.util.concurrent.Future future
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    7     2  future  Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
            3    4     3     res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
            5    6     3     res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
    Exceptions:
      throws java.lang.Exception

  private void lambda$10(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 1 // java.lang.Object v
         0: .line 353
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.callDrainHandler:()V
            return
        end local 1 // java.lang.Object v
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    1     1     v  Ljava/lang/Object;

  private void lambda$12(java.lang.Object, java.lang.Object);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.core.net.impl.NetSocketImpl this
        start local 2 // java.lang.Object o
         0: .line 382
            aload 0 /* this */
            getfield io.vertx.core.net.impl.NetSocketImpl.pending:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 1
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.write:(Ljava/lang/Object;)Z
            ifne 2
         1: .line 383
            aload 0 /* this */
            invokevirtual io.vertx.core.net.impl.NetSocketImpl.doPause:()V
         2: .line 385
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Object o
        end local 0 // io.vertx.core.net.impl.NetSocketImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/core/net/impl/NetSocketImpl;
            0    3     2     o  Ljava/lang/Object;

  private static void lambda$7(io.vertx.core.Handler, io.vertx.core.AsyncResult, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Void v
         0: .line 271
            aload 0
            aload 1
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
            return
        end local 2 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     2     v  Ljava/lang/Void;
}
SourceFile: "NetSocketImpl.java"
NestMembers:
  io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler
InnerClasses:
  private DataMessageHandler = io.vertx.core.net.impl.NetSocketImpl$DataMessageHandler of io.vertx.core.net.impl.NetSocketImpl
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles