class io.vertx.core.http.impl.ConnectionManager
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: io.vertx.core.http.impl.ConnectionManager
  super_class: java.lang.Object
{
  private static final java.util.function.LongSupplier CLOCK;
    descriptor: Ljava/util/function/LongSupplier;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final int maxWaitQueueSize;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  private final io.vertx.core.http.impl.HttpClientImpl client;
    descriptor: Lio/vertx/core/http/impl/HttpClientImpl;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.Map<io.netty.channel.Channel, io.vertx.core.http.impl.HttpClientConnection> connectionMap;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Lio/netty/channel/Channel;Lio/vertx/core/http/impl/HttpClientConnection;>;

  private final java.util.Map<io.vertx.core.http.impl.ConnectionManager$EndpointKey, io.vertx.core.http.impl.ConnectionManager$Endpoint> endpointMap;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;Lio/vertx/core/http/impl/ConnectionManager$Endpoint;>;

  private final io.vertx.core.http.HttpVersion version;
    descriptor: Lio/vertx/core/http/HttpVersion;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long maxSize;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private long timerID;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 36
            invokedynamic getAsLong()Ljava/util/function/LongSupplier;
              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:
                  ()J
                  java/lang/System.currentTimeMillis()J (6)
                  ()J
            putstatic io.vertx.core.http.impl.ConnectionManager.CLOCK:Ljava/util/function/LongSupplier;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(io.vertx.core.http.impl.HttpClientImpl, io.vertx.core.spi.metrics.HttpClientMetrics, io.vertx.core.http.HttpVersion, long, int);
    descriptor: (Lio/vertx/core/http/impl/HttpClientImpl;Lio/vertx/core/spi/metrics/HttpClientMetrics;Lio/vertx/core/http/HttpVersion;JI)V
    flags: (0x0000) 
    Code:
      stack=3, locals=7, args_size=6
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 1 // io.vertx.core.http.impl.HttpClientImpl client
        start local 2 // io.vertx.core.spi.metrics.HttpClientMetrics metrics
        start local 3 // io.vertx.core.http.HttpVersion version
        start local 4 // long maxSize
        start local 6 // int maxWaitQueueSize
         0: .line 47
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 41
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield io.vertx.core.http.impl.ConnectionManager.connectionMap:Ljava/util/Map;
         2: .line 42
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield io.vertx.core.http.impl.ConnectionManager.endpointMap:Ljava/util/Map;
         3: .line 52
            aload 0 /* this */
            aload 1 /* client */
            putfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
         4: .line 53
            aload 0 /* this */
            iload 6 /* maxWaitQueueSize */
            putfield io.vertx.core.http.impl.ConnectionManager.maxWaitQueueSize:I
         5: .line 54
            aload 0 /* this */
            aload 2 /* metrics */
            putfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
         6: .line 55
            aload 0 /* this */
            lload 4 /* maxSize */
            putfield io.vertx.core.http.impl.ConnectionManager.maxSize:J
         7: .line 56
            aload 0 /* this */
            aload 3 /* version */
            putfield io.vertx.core.http.impl.ConnectionManager.version:Lio/vertx/core/http/HttpVersion;
         8: .line 57
            return
        end local 6 // int maxWaitQueueSize
        end local 4 // long maxSize
        end local 3 // io.vertx.core.http.HttpVersion version
        end local 2 // io.vertx.core.spi.metrics.HttpClientMetrics metrics
        end local 1 // io.vertx.core.http.impl.HttpClientImpl client
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    9     0              this  Lio/vertx/core/http/impl/ConnectionManager;
            0    9     1            client  Lio/vertx/core/http/impl/HttpClientImpl;
            0    9     2           metrics  Lio/vertx/core/spi/metrics/HttpClientMetrics;
            0    9     3           version  Lio/vertx/core/http/HttpVersion;
            0    9     4           maxSize  J
            0    9     6  maxWaitQueueSize  I
    MethodParameters:
                  Name  Flags
      client            
      metrics           
      version           
      maxSize           
      maxWaitQueueSize  

  synchronized void start();
    descriptor: ()V
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=7, locals=3, args_size=1
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
         0: .line 60
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.getPoolCleanerPeriod:()I
            i2l
            lstore 1 /* period */
        start local 1 // long period
         1: .line 61
            aload 0 /* this */
            lload 1 /* period */
            lconst_0
            lcmp
            ifle 2
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientImpl.getVertx:()Lio/vertx/core/impl/VertxInternal;
            lload 1 /* period */
            aload 0 /* this */
            lload 1 /* period */
            invokedynamic handle(Lio/vertx/core/http/impl/ConnectionManager;J)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/http/impl/ConnectionManager.lambda$1(JLjava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.impl.VertxInternal.setTimer:(JLio/vertx/core/Handler;)J
            goto 3
      StackMap locals: io.vertx.core.http.impl.ConnectionManager long
      StackMap stack: io.vertx.core.http.impl.ConnectionManager
         2: ldc -1
      StackMap locals: io.vertx.core.http.impl.ConnectionManager long
      StackMap stack: io.vertx.core.http.impl.ConnectionManager long
         3: putfield io.vertx.core.http.impl.ConnectionManager.timerID:J
         4: .line 62
            return
        end local 1 // long period
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lio/vertx/core/http/impl/ConnectionManager;
            1    5     1  period  J

  private synchronized void checkExpired(long);
    descriptor: (J)V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=7, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 1 // long period
         0: .line 65
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.endpointMap:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokedynamic accept()Ljava/util/function/Consumer;
              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/http/impl/ConnectionManager.lambda$2(Lio/vertx/core/http/impl/ConnectionManager$Endpoint;)V (6)
                  (Lio/vertx/core/http/impl/ConnectionManager$Endpoint;)V
            invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
         1: .line 66
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientImpl.getVertx:()Lio/vertx/core/impl/VertxInternal;
            lload 1 /* period */
            aload 0 /* this */
            lload 1 /* period */
            invokedynamic handle(Lio/vertx/core/http/impl/ConnectionManager;J)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/http/impl/ConnectionManager.lambda$3(JLjava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.impl.VertxInternal.setTimer:(JLio/vertx/core/Handler;)J
            putfield io.vertx.core.http.impl.ConnectionManager.timerID:J
         2: .line 67
            return
        end local 1 // long period
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lio/vertx/core/http/impl/ConnectionManager;
            0    3     1  period  J
    MethodParameters:
        Name  Flags
      period  

  void getConnection(io.vertx.core.impl.ContextInternal, io.vertx.core.net.SocketAddress, boolean, io.vertx.core.net.SocketAddress, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.impl.HttpClientConnection>>);
    descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/SocketAddress;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/Handler;)V
    flags: (0x0000) 
    Code:
      stack=8, locals=9, args_size=6
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 1 // io.vertx.core.impl.ContextInternal ctx
        start local 2 // io.vertx.core.net.SocketAddress peerAddress
        start local 3 // boolean ssl
        start local 4 // io.vertx.core.net.SocketAddress server
        start local 5 // io.vertx.core.Handler handler
         0: .line 116
            new io.vertx.core.http.impl.ConnectionManager$EndpointKey
            dup
            iload 3 /* ssl */
            aload 4 /* server */
            aload 2 /* peerAddress */
            invokespecial io.vertx.core.http.impl.ConnectionManager$EndpointKey.<init>:(ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/net/SocketAddress;)V
            astore 6 /* key */
        start local 6 // io.vertx.core.http.impl.ConnectionManager$EndpointKey key
         1: .line 118
      StackMap locals: io.vertx.core.http.impl.ConnectionManager$EndpointKey
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.endpointMap:Ljava/util/Map;
            aload 6 /* key */
            aload 0 /* this */
            aload 6 /* key */
            aload 4 /* server */
            iload 3 /* ssl */
            aload 2 /* peerAddress */
            aload 1 /* ctx */
            invokedynamic apply(Lio/vertx/core/http/impl/ConnectionManager;Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;Lio/vertx/core/net/SocketAddress;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;)Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  io/vertx/core/http/impl/ConnectionManager.lambda$4(Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;Lio/vertx/core/net/SocketAddress;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;)Lio/vertx/core/http/impl/ConnectionManager$Endpoint; (7)
                  (Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;)Lio/vertx/core/http/impl/ConnectionManager$Endpoint;
            invokeinterface java.util.Map.computeIfAbsent:(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;
            checkcast io.vertx.core.http.impl.ConnectionManager$Endpoint
            astore 7 /* endpoint */
        start local 7 // io.vertx.core.http.impl.ConnectionManager$Endpoint endpoint
         2: .line 144
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 5
         3: .line 145
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 7 /* endpoint */
            getfield io.vertx.core.http.impl.ConnectionManager$Endpoint.metric:Ljava/lang/Object;
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.enqueueRequest:(Ljava/lang/Object;)Ljava/lang/Object;
            astore 8 /* metric */
        start local 8 // java.lang.Object metric
         4: .line 146
            goto 6
        end local 8 // java.lang.Object metric
         5: .line 147
      StackMap locals: io.vertx.core.http.impl.ConnectionManager$Endpoint
      StackMap stack:
            aconst_null
            astore 8 /* metric */
        start local 8 // java.lang.Object metric
         6: .line 150
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 7 /* endpoint */
            getfield io.vertx.core.http.impl.ConnectionManager$Endpoint.pool:Lio/vertx/core/http/impl/pool/Pool;
            aload 0 /* this */
            aload 7 /* endpoint */
            aload 8 /* metric */
            aload 5 /* handler */
            invokedynamic handle(Lio/vertx/core/http/impl/ConnectionManager;Lio/vertx/core/http/impl/ConnectionManager$Endpoint;Ljava/lang/Object;Lio/vertx/core/Handler;)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/http/impl/ConnectionManager.lambda$8(Lio/vertx/core/http/impl/ConnectionManager$Endpoint;Ljava/lang/Object;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokevirtual io.vertx.core.http.impl.pool.Pool.getConnection:(Lio/vertx/core/Handler;)Z
         7: .line 155
            ifeq 1
        end local 8 // java.lang.Object metric
        end local 7 // io.vertx.core.http.impl.ConnectionManager$Endpoint endpoint
         8: .line 159
            return
        end local 6 // io.vertx.core.http.impl.ConnectionManager$EndpointKey key
        end local 5 // io.vertx.core.Handler handler
        end local 4 // io.vertx.core.net.SocketAddress server
        end local 3 // boolean ssl
        end local 2 // io.vertx.core.net.SocketAddress peerAddress
        end local 1 // io.vertx.core.impl.ContextInternal ctx
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    9     0         this  Lio/vertx/core/http/impl/ConnectionManager;
            0    9     1          ctx  Lio/vertx/core/impl/ContextInternal;
            0    9     2  peerAddress  Lio/vertx/core/net/SocketAddress;
            0    9     3          ssl  Z
            0    9     4       server  Lio/vertx/core/net/SocketAddress;
            0    9     5      handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientConnection;>;>;
            1    9     6          key  Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;
            2    8     7     endpoint  Lio/vertx/core/http/impl/ConnectionManager$Endpoint;
            4    5     8       metric  Ljava/lang/Object;
            6    8     8       metric  Ljava/lang/Object;
    Signature: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/SocketAddress;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientConnection;>;>;)V
    MethodParameters:
             Name  Flags
      ctx          
      peerAddress  
      ssl          
      server       
      handler      

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
         0: .line 162
            aload 0 /* this */
            dup
            astore 1
            monitorenter
         1: .line 163
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.timerID:J
            lconst_0
            lcmp
            iflt 4
         2: .line 164
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientImpl.getVertx:()Lio/vertx/core/impl/VertxInternal;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.timerID:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         3: .line 165
            aload 0 /* this */
            ldc -1
            putfield io.vertx.core.http.impl.ConnectionManager.timerID:J
         4: .line 162
      StackMap locals: io.vertx.core.http.impl.ConnectionManager
      StackMap stack:
            aload 1
            monitorexit
         5: goto 8
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: aload 1
            monitorexit
         7: athrow
         8: .line 168
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.endpointMap:Ljava/util/Map;
            invokeinterface java.util.Map.clear:()V
         9: .line 169
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.connectionMap:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 2
            goto 12
      StackMap locals: io.vertx.core.http.impl.ConnectionManager top java.util.Iterator
      StackMap stack:
        10: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.core.http.impl.HttpClientConnection
            astore 1 /* conn */
        start local 1 // io.vertx.core.http.impl.HttpClientConnection conn
        11: .line 170
            aload 1 /* conn */
            invokeinterface io.vertx.core.http.impl.HttpClientConnection.close:()V
        end local 1 // io.vertx.core.http.impl.HttpClientConnection conn
        12: .line 169
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 10
        13: .line 172
            return
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   14     0  this  Lio/vertx/core/http/impl/ConnectionManager;
           11   12     1  conn  Lio/vertx/core/http/impl/HttpClientConnection;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any

  private void lambda$1(long, java.lang.Long);
    descriptor: (JLjava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 3 // java.lang.Long id
         0: .line 61
            aload 0 /* this */
            lload 1
            invokevirtual io.vertx.core.http.impl.ConnectionManager.checkExpired:(J)V
            return
        end local 3 // java.lang.Long id
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/ConnectionManager;
            0    1     3    id  Ljava/lang/Long;

  private static void lambda$2(io.vertx.core.http.impl.ConnectionManager$Endpoint);
    descriptor: (Lio/vertx/core/http/impl/ConnectionManager$Endpoint;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.ConnectionManager$Endpoint e
         0: .line 65
            aload 0 /* e */
            getfield io.vertx.core.http.impl.ConnectionManager$Endpoint.pool:Lio/vertx/core/http/impl/pool/Pool;
            invokevirtual io.vertx.core.http.impl.pool.Pool.closeIdle:()V
            return
        end local 0 // io.vertx.core.http.impl.ConnectionManager$Endpoint e
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     e  Lio/vertx/core/http/impl/ConnectionManager$Endpoint;

  private void lambda$3(long, java.lang.Long);
    descriptor: (JLjava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 3 // java.lang.Long id
         0: .line 66
            aload 0 /* this */
            lload 1
            invokevirtual io.vertx.core.http.impl.ConnectionManager.checkExpired:(J)V
            return
        end local 3 // java.lang.Long id
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/ConnectionManager;
            0    1     3    id  Ljava/lang/Long;

  private io.vertx.core.http.impl.ConnectionManager$Endpoint lambda$4(io.vertx.core.http.impl.ConnectionManager$EndpointKey, io.vertx.core.net.SocketAddress, boolean, io.vertx.core.net.SocketAddress, io.vertx.core.impl.ContextInternal, io.vertx.core.http.impl.ConnectionManager$EndpointKey);
    descriptor: (Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;Lio/vertx/core/net/SocketAddress;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;)Lio/vertx/core/http/impl/ConnectionManager$Endpoint;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=15, locals=13, args_size=7
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 6 // io.vertx.core.http.impl.ConnectionManager$EndpointKey targetAddress
         0: .line 119
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.getMaxPoolSize:()I
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientImpl.getOptions:()Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.getHttp2MaxPoolSize:()I
            invokestatic java.lang.Math.max:(II)I
            istore 7 /* maxPoolSize */
        start local 7 // int maxPoolSize
         1: .line 122
            aload 2
            invokeinterface io.vertx.core.net.SocketAddress.path:()Ljava/lang/String;
            ifnonnull 5
         2: .line 123
            aload 2
            invokeinterface io.vertx.core.net.SocketAddress.host:()Ljava/lang/String;
            astore 8 /* host */
        start local 8 // java.lang.String host
         3: .line 124
            aload 2
            invokeinterface io.vertx.core.net.SocketAddress.port:()I
            istore 9 /* port */
        start local 9 // int port
         4: .line 125
            goto 7
        end local 9 // int port
        end local 8 // java.lang.String host
         5: .line 126
      StackMap locals: int
      StackMap stack:
            aload 2
            invokeinterface io.vertx.core.net.SocketAddress.path:()Ljava/lang/String;
            astore 8 /* host */
        start local 8 // java.lang.String host
         6: .line 127
            iconst_0
            istore 9 /* port */
        start local 9 // int port
         7: .line 129
      StackMap locals: java.lang.String int
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 8
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 8 /* host */
            iload 9 /* port */
            iload 7 /* maxPoolSize */
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.createEndpoint:(Ljava/lang/String;II)Ljava/lang/Object;
            goto 9
      StackMap locals:
      StackMap stack:
         8: aconst_null
      StackMap locals:
      StackMap stack: java.lang.Object
         9: astore 10 /* metric */
        start local 10 // java.lang.Object metric
        10: .line 130
            new io.vertx.core.http.impl.HttpChannelConnector
            dup
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.client:Lio/vertx/core/http/impl/HttpClientImpl;
            aload 10 /* metric */
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.version:Lio/vertx/core/http/HttpVersion;
            iload 3
            aload 4
            aload 2
            invokespecial io.vertx.core.http.impl.HttpChannelConnector.<init>:(Lio/vertx/core/http/impl/HttpClientImpl;Ljava/lang/Object;Lio/vertx/core/http/HttpVersion;ZLio/vertx/core/net/SocketAddress;Lio/vertx/core/net/SocketAddress;)V
            astore 11 /* connector */
        start local 11 // io.vertx.core.http.impl.HttpChannelConnector connector
        11: .line 131
            new io.vertx.core.http.impl.pool.Pool
            dup
            aload 5
            aload 11 /* connector */
            getstatic io.vertx.core.http.impl.ConnectionManager.CLOCK:Ljava/util/function/LongSupplier;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.maxWaitQueueSize:I
            aload 11 /* connector */
            invokevirtual io.vertx.core.http.impl.HttpChannelConnector.weight:()J
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.maxSize:J
        12: .line 132
            aload 0 /* this */
            aload 8 /* host */
            iload 9 /* port */
            aload 10 /* metric */
            aload 1
            invokedynamic handle(Lio/vertx/core/http/impl/ConnectionManager;Ljava/lang/String;ILjava/lang/Object;Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;)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/http/impl/ConnectionManager.lambda$5(Ljava/lang/String;ILjava/lang/Object;Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
        13: .line 138
            aload 0 /* this */
            invokedynamic accept(Lio/vertx/core/http/impl/ConnectionManager;)Ljava/util/function/Consumer;
              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/http/impl/ConnectionManager.lambda$6(Lio/vertx/core/http/impl/HttpClientConnection;)V (7)
                  (Lio/vertx/core/http/impl/HttpClientConnection;)V
        14: .line 139
            aload 0 /* this */
            invokedynamic accept(Lio/vertx/core/http/impl/ConnectionManager;)Ljava/util/function/Consumer;
              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/http/impl/ConnectionManager.lambda$7(Lio/vertx/core/http/impl/HttpClientConnection;)V (7)
                  (Lio/vertx/core/http/impl/HttpClientConnection;)V
        15: .line 140
            iconst_0
        16: .line 131
            invokespecial io.vertx.core.http.impl.pool.Pool.<init>:(Lio/vertx/core/Context;Lio/vertx/core/http/impl/pool/ConnectionProvider;Ljava/util/function/LongSupplier;IJJLio/vertx/core/Handler;Ljava/util/function/Consumer;Ljava/util/function/Consumer;Z)V
            astore 12 /* pool */
        start local 12 // io.vertx.core.http.impl.pool.Pool pool
        17: .line 141
            new io.vertx.core.http.impl.ConnectionManager$Endpoint
            dup
            aload 0 /* this */
            aload 12 /* pool */
            aload 10 /* metric */
            invokespecial io.vertx.core.http.impl.ConnectionManager$Endpoint.<init>:(Lio/vertx/core/http/impl/ConnectionManager;Lio/vertx/core/http/impl/pool/Pool;Ljava/lang/Object;)V
            areturn
        end local 12 // io.vertx.core.http.impl.pool.Pool pool
        end local 11 // io.vertx.core.http.impl.HttpChannelConnector connector
        end local 10 // java.lang.Object metric
        end local 9 // int port
        end local 8 // java.lang.String host
        end local 7 // int maxPoolSize
        end local 6 // io.vertx.core.http.impl.ConnectionManager$EndpointKey targetAddress
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   18     0           this  Lio/vertx/core/http/impl/ConnectionManager;
            0   18     6  targetAddress  Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;
            1   18     7    maxPoolSize  I
            3    5     8           host  Ljava/lang/String;
            6   18     8           host  Ljava/lang/String;
            4    5     9           port  I
            7   18     9           port  I
           10   18    10         metric  Ljava/lang/Object;
           11   18    11      connector  Lio/vertx/core/http/impl/HttpChannelConnector;
           17   18    12           pool  Lio/vertx/core/http/impl/pool/Pool<Lio/vertx/core/http/impl/HttpClientConnection;>;

  private void lambda$8(io.vertx.core.http.impl.ConnectionManager$Endpoint, java.lang.Object, io.vertx.core.Handler, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/http/impl/ConnectionManager$Endpoint;Ljava/lang/Object;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=5
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 4 // io.vertx.core.AsyncResult ar
         0: .line 151
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 2
         1: .line 152
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 1
            getfield io.vertx.core.http.impl.ConnectionManager$Endpoint.metric:Ljava/lang/Object;
            aload 2
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.dequeueRequest:(Ljava/lang/Object;Ljava/lang/Object;)V
         2: .line 154
      StackMap locals:
      StackMap stack:
            aload 3
            aload 4 /* ar */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 155
            return
        end local 4 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/core/http/impl/ConnectionManager;
            0    4     4    ar  Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientConnection;>;

  private void lambda$5(java.lang.String, int, java.lang.Object, io.vertx.core.http.impl.ConnectionManager$EndpointKey, java.lang.Void);
    descriptor: (Ljava/lang/String;ILjava/lang/Object;Lio/vertx/core/http/impl/ConnectionManager$EndpointKey;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=6, args_size=6
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 5 // java.lang.Void v
         0: .line 133
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 2
         1: .line 134
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 1
            iload 2
            aload 3
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.closeEndpoint:(Ljava/lang/String;ILjava/lang/Object;)V
         2: .line 136
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.endpointMap:Ljava/util/Map;
            aload 4
            invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 137
            return
        end local 5 // java.lang.Void v
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/core/http/impl/ConnectionManager;
            0    4     5     v  Ljava/lang/Void;

  private void lambda$6(io.vertx.core.http.impl.HttpClientConnection);
    descriptor: (Lio/vertx/core/http/impl/HttpClientConnection;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 1 // io.vertx.core.http.impl.HttpClientConnection conn
         0: .line 138
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.connectionMap:Ljava/util/Map;
            aload 1 /* conn */
            invokeinterface io.vertx.core.http.impl.HttpClientConnection.channel:()Lio/netty/channel/Channel;
            aload 1 /* conn */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            return
        end local 1 // io.vertx.core.http.impl.HttpClientConnection conn
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/ConnectionManager;
            0    1     1  conn  Lio/vertx/core/http/impl/HttpClientConnection;

  private void lambda$7(io.vertx.core.http.impl.HttpClientConnection);
    descriptor: (Lio/vertx/core/http/impl/HttpClientConnection;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.ConnectionManager this
        start local 1 // io.vertx.core.http.impl.HttpClientConnection conn
         0: .line 139
            aload 0 /* this */
            getfield io.vertx.core.http.impl.ConnectionManager.connectionMap:Ljava/util/Map;
            aload 1 /* conn */
            invokeinterface io.vertx.core.http.impl.HttpClientConnection.channel:()Lio/netty/channel/Channel;
            aload 1 /* conn */
            invokeinterface java.util.Map.remove:(Ljava/lang/Object;Ljava/lang/Object;)Z
            return
        end local 1 // io.vertx.core.http.impl.HttpClientConnection conn
        end local 0 // io.vertx.core.http.impl.ConnectionManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/ConnectionManager;
            0    1     1  conn  Lio/vertx/core/http/impl/HttpClientConnection;
}
SourceFile: "ConnectionManager.java"
NestMembers:
  io.vertx.core.http.impl.ConnectionManager$Endpoint  io.vertx.core.http.impl.ConnectionManager$EndpointKey
InnerClasses:
  Endpoint = io.vertx.core.http.impl.ConnectionManager$Endpoint of io.vertx.core.http.impl.ConnectionManager
  private final EndpointKey = io.vertx.core.http.impl.ConnectionManager$EndpointKey of io.vertx.core.http.impl.ConnectionManager
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles