class io.vertx.core.http.impl.Http1xClientConnection$StreamImpl implements io.vertx.core.http.impl.HttpClientStream
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
  super_class: java.lang.Object
{
  private final int id;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  private final io.vertx.core.Promise<io.vertx.core.http.impl.HttpClientStream> fut;
    descriptor: Lio/vertx/core/Promise;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lio/vertx/core/Promise<Lio/vertx/core/http/impl/HttpClientStream;>;

  private final io.vertx.core.streams.impl.InboundBuffer<java.lang.Object> queue;
    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.http.impl.HttpClientRequestImpl request;
    descriptor: Lio/vertx/core/http/impl/HttpClientRequestImpl;
    flags: (0x0002) ACC_PRIVATE

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

  private io.vertx.core.http.impl.HttpClientResponseImpl response;
    descriptor: Lio/vertx/core/http/impl/HttpClientResponseImpl;
    flags: (0x0002) ACC_PRIVATE

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

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

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

  private io.vertx.core.http.impl.Http1xClientConnection$StreamImpl next;
    descriptor: Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
    flags: (0x0002) ACC_PRIVATE

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

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

  private java.lang.Object metric;
    descriptor: Ljava/lang/Object;
    flags: (0x0002) ACC_PRIVATE

  void <init>(io.vertx.core.http.impl.Http1xClientConnection, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.http.impl.HttpClientStream>>);
    descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection;ILio/vertx/core/Handler;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.impl.Http1xClientConnection conn
        start local 2 // int id
        start local 3 // io.vertx.core.Handler handler
         0: .line 204
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 205
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 4 /* promise */
        start local 4 // io.vertx.core.Promise promise
         2: .line 206
            aload 4 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 3 /* handler */
            invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 208
            aload 0 /* this */
            aload 1 /* conn */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
         4: .line 209
            aload 0 /* this */
            aload 4 /* promise */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.fut:Lio/vertx/core/Promise;
         5: .line 210
            aload 0 /* this */
            iload 2 /* id */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.id:I
         6: .line 211
            aload 0 /* this */
            new io.vertx.core.streams.impl.InboundBuffer
            dup
            aload 1 /* conn */
            invokestatic io.vertx.core.http.impl.Http1xClientConnection.access$1:(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
            ldc 5
            invokespecial io.vertx.core.streams.impl.InboundBuffer.<init>:(Lio/vertx/core/Context;J)V
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
         7: .line 212
            return
        end local 4 // io.vertx.core.Promise promise
        end local 3 // io.vertx.core.Handler handler
        end local 2 // int id
        end local 1 // io.vertx.core.http.impl.Http1xClientConnection conn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    8     1     conn  Lio/vertx/core/http/impl/Http1xClientConnection;
            0    8     2       id  I
            0    8     3  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;
            2    8     4  promise  Lio/vertx/core/Promise<Lio/vertx/core/http/impl/HttpClientStream;>;
    Signature: (Lio/vertx/core/http/impl/Http1xClientConnection;ILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/http/impl/HttpClientStream;>;>;)V
    MethodParameters:
         Name  Flags
      conn     
      id       
      handler  

  private void append(io.vertx.core.http.impl.Http1xClientConnection$StreamImpl);
    descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl s
         0: .line 215
            aload 0 /* this */
            astore 2 /* c */
        start local 2 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl c
         1: .line 216
            goto 3
         2: .line 217
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
      StackMap stack:
            aload 2 /* c */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            astore 2 /* c */
         3: .line 216
      StackMap locals:
      StackMap stack:
            aload 2 /* c */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            ifnonnull 2
         4: .line 219
            aload 2 /* c */
            aload 1 /* s */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
         5: .line 220
            return
        end local 2 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl c
        end local 1 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl s
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    6     1     s  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            1    6     2     c  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
    MethodParameters:
      Name  Flags
      s     

  public int id();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 224
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.id:I
            ireturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public java.lang.Object metric();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 229
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.metric:Ljava/lang/Object;
            areturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public io.vertx.core.http.HttpVersion version();
    descriptor: ()Lio/vertx/core/http/HttpVersion;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 234
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.version:Lio/vertx/core/http/HttpVersion;
            areturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public io.vertx.core.http.impl.HttpClientConnection connection();
    descriptor: ()Lio/vertx/core/http/impl/HttpClientConnection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 239
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            areturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public io.vertx.core.Context getContext();
    descriptor: ()Lio/vertx/core/Context;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 244
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokestatic io.vertx.core.http.impl.Http1xClientConnection.access$1:(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
            areturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public void writeHead(io.vertx.core.http.HttpMethod, java.lang.String, java.lang.String, io.vertx.core.MultiMap, java.lang.String, boolean, io.netty.buffer.ByteBuf, boolean, io.vertx.core.http.StreamPriority, io.vertx.core.Handler<java.lang.Void>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/MultiMap;Ljava/lang/String;ZLio/netty/buffer/ByteBuf;ZLio/vertx/core/http/StreamPriority;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=13, args_size=12
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.HttpMethod method
        start local 2 // java.lang.String rawMethod
        start local 3 // java.lang.String uri
        start local 4 // io.vertx.core.MultiMap headers
        start local 5 // java.lang.String hostHeader
        start local 6 // boolean chunked
        start local 7 // io.netty.buffer.ByteBuf buf
        start local 8 // boolean end
        start local 9 // io.vertx.core.http.StreamPriority priority
        start local 10 // io.vertx.core.Handler contHandler
        start local 11 // io.vertx.core.Handler handler
         0: .line 249
            aload 0 /* this */
            aload 1 /* method */
            aload 2 /* rawMethod */
            aload 3 /* uri */
            aload 4 /* headers */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.createRequest:(Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/MultiMap;)Lio/netty/handler/codec/http/HttpRequest;
            astore 12 /* request */
        start local 12 // io.netty.handler.codec.http.HttpRequest request
         1: .line 250
            aload 0 /* this */
            aload 12 /* request */
            aload 5 /* hostHeader */
            iload 6 /* chunked */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.prepareRequestHeaders:(Lio/netty/handler/codec/http/HttpRequest;Ljava/lang/String;Z)V
         2: .line 251
            aload 7 /* buf */
            ifnull 4
         3: .line 252
            aload 0 /* this */
            dup
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesWritten:J
            aload 7 /* buf */
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            ladd
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesWritten:J
         4: .line 254
      StackMap locals: io.netty.handler.codec.http.HttpRequest
      StackMap stack:
            aload 0 /* this */
            aload 10 /* contHandler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.continueHandler:Lio/vertx/core/Handler;
         5: .line 255
            aload 0 /* this */
            aload 12 /* request */
            aload 7 /* buf */
            iload 8 /* end */
            aload 11 /* handler */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.sendRequest:(Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
         6: .line 256
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            ifnonnull 9
         7: .line 257
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 0 /* this */
            putfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
         8: .line 258
            goto 10
         9: .line 259
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.responseInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            aload 0 /* this */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.append:(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)V
        10: .line 261
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.next:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
        11: .line 262
            return
        end local 12 // io.netty.handler.codec.http.HttpRequest request
        end local 11 // io.vertx.core.Handler handler
        end local 10 // io.vertx.core.Handler contHandler
        end local 9 // io.vertx.core.http.StreamPriority priority
        end local 8 // boolean end
        end local 7 // io.netty.buffer.ByteBuf buf
        end local 6 // boolean chunked
        end local 5 // java.lang.String hostHeader
        end local 4 // io.vertx.core.MultiMap headers
        end local 3 // java.lang.String uri
        end local 2 // java.lang.String rawMethod
        end local 1 // io.vertx.core.http.HttpMethod method
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   12     0         this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   12     1       method  Lio/vertx/core/http/HttpMethod;
            0   12     2    rawMethod  Ljava/lang/String;
            0   12     3          uri  Ljava/lang/String;
            0   12     4      headers  Lio/vertx/core/MultiMap;
            0   12     5   hostHeader  Ljava/lang/String;
            0   12     6      chunked  Z
            0   12     7          buf  Lio/netty/buffer/ByteBuf;
            0   12     8          end  Z
            0   12     9     priority  Lio/vertx/core/http/StreamPriority;
            0   12    10  contHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
            0   12    11      handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1   12    12      request  Lio/netty/handler/codec/http/HttpRequest;
    Signature: (Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/MultiMap;Ljava/lang/String;ZLio/netty/buffer/ByteBuf;ZLio/vertx/core/http/StreamPriority;Lio/vertx/core/Handler<Ljava/lang/Void;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
             Name  Flags
      method       
      rawMethod    
      uri          
      headers      
      hostHeader   
      chunked      
      buf          
      end          
      priority     
      contHandler  
      handler      

  private io.netty.handler.codec.http.HttpRequest createRequest(io.vertx.core.http.HttpMethod, java.lang.String, java.lang.String, io.vertx.core.MultiMap);
    descriptor: (Lio/vertx/core/http/HttpMethod;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/MultiMap;)Lio/netty/handler/codec/http/HttpRequest;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=8, args_size=5
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.HttpMethod method
        start local 2 // java.lang.String rawMethod
        start local 3 // java.lang.String uri
        start local 4 // io.vertx.core.MultiMap headers
         0: .line 265
            new io.netty.handler.codec.http.DefaultHttpRequest
            dup
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.version:Lio/vertx/core/http/HttpVersion;
            invokestatic io.vertx.core.http.impl.HttpUtils.toNettyHttpVersion:(Lio/vertx/core/http/HttpVersion;)Lio/netty/handler/codec/http/HttpVersion;
            aload 1 /* method */
            aload 2 /* rawMethod */
            invokestatic io.vertx.core.http.impl.HttpUtils.toNettyHttpMethod:(Lio/vertx/core/http/HttpMethod;Ljava/lang/String;)Lio/netty/handler/codec/http/HttpMethod;
            aload 3 /* uri */
            iconst_0
            invokespecial io.netty.handler.codec.http.DefaultHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpMethod;Ljava/lang/String;Z)V
            astore 5 /* request */
        start local 5 // io.netty.handler.codec.http.DefaultHttpRequest request
         1: .line 266
            aload 4 /* headers */
            ifnull 6
         2: .line 267
            aload 4 /* headers */
            invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
            astore 7
            goto 5
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.HttpMethod java.lang.String java.lang.String io.vertx.core.MultiMap io.netty.handler.codec.http.DefaultHttpRequest top java.util.Iterator
      StackMap stack:
         3: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.util.Map$Entry
            astore 6 /* header */
        start local 6 // java.util.Map$Entry header
         4: .line 269
            aload 5 /* request */
            invokevirtual io.netty.handler.codec.http.DefaultHttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            aload 6 /* header */
            invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
            checkcast java.lang.String
            aload 6 /* header */
            invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.add:(Ljava/lang/String;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
        end local 6 // java.util.Map$Entry header
         5: .line 267
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         6: .line 272
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.HttpMethod java.lang.String java.lang.String io.vertx.core.MultiMap io.netty.handler.codec.http.DefaultHttpRequest
      StackMap stack:
            aload 5 /* request */
            areturn
        end local 5 // io.netty.handler.codec.http.DefaultHttpRequest request
        end local 4 // io.vertx.core.MultiMap headers
        end local 3 // java.lang.String uri
        end local 2 // java.lang.String rawMethod
        end local 1 // io.vertx.core.http.HttpMethod method
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    7     1     method  Lio/vertx/core/http/HttpMethod;
            0    7     2  rawMethod  Ljava/lang/String;
            0    7     3        uri  Ljava/lang/String;
            0    7     4    headers  Lio/vertx/core/MultiMap;
            1    7     5    request  Lio/netty/handler/codec/http/DefaultHttpRequest;
            4    5     6     header  Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
    MethodParameters:
           Name  Flags
      method     
      rawMethod  
      uri        
      headers    

  private void prepareRequestHeaders(io.netty.handler.codec.http.HttpRequest, java.lang.String, boolean);
    descriptor: (Lio/netty/handler/codec/http/HttpRequest;Ljava/lang/String;Z)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.netty.handler.codec.http.HttpRequest request
        start local 2 // java.lang.String hostHeader
        start local 3 // boolean chunked
         0: .line 276
            aload 1 /* request */
            invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            astore 4 /* headers */
        start local 4 // io.netty.handler.codec.http.HttpHeaders headers
         1: .line 277
            aload 4 /* headers */
            getstatic io.vertx.core.http.HttpHeaders.TRANSFER_ENCODING:Ljava/lang/CharSequence;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.remove:(Ljava/lang/CharSequence;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
         2: .line 278
            aload 4 /* headers */
            getstatic io.vertx.core.http.HttpHeaders.HOST:Ljava/lang/CharSequence;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.contains:(Ljava/lang/CharSequence;)Z
            ifne 4
         3: .line 279
            aload 1 /* request */
            invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.vertx.core.http.HttpHeaders.HOST:Ljava/lang/CharSequence;
            aload 2 /* hostHeader */
            invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
         4: .line 281
      StackMap locals: io.netty.handler.codec.http.HttpHeaders
      StackMap stack:
            iload 3 /* chunked */
            ifeq 6
         5: .line 282
            aload 1 /* request */
            iconst_1
            invokestatic io.netty.handler.codec.http.HttpUtil.setTransferEncodingChunked:(Lio/netty/handler/codec/http/HttpMessage;Z)V
         6: .line 284
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.isTryUseCompression:()Z
            ifeq 8
            aload 1 /* request */
            invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.vertx.core.http.HttpHeaders.ACCEPT_ENCODING:Ljava/lang/CharSequence;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
            ifnonnull 8
         7: .line 286
            aload 1 /* request */
            invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.vertx.core.http.HttpHeaders.ACCEPT_ENCODING:Ljava/lang/CharSequence;
            getstatic io.vertx.core.http.HttpHeaders.DEFLATE_GZIP:Ljava/lang/CharSequence;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
         8: .line 288
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.isKeepAlive:()Z
            ifne 11
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.getProtocolVersion:()Lio/vertx/core/http/HttpVersion;
            getstatic io.vertx.core.http.HttpVersion.HTTP_1_1:Lio/vertx/core/http/HttpVersion;
            if_acmpne 11
         9: .line 289
            aload 1 /* request */
            invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.vertx.core.http.HttpHeaders.CONNECTION:Ljava/lang/CharSequence;
            getstatic io.vertx.core.http.HttpHeaders.CLOSE:Ljava/lang/CharSequence;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
        10: .line 290
            goto 13
      StackMap locals:
      StackMap stack:
        11: aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.isKeepAlive:()Z
            ifeq 13
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.getProtocolVersion:()Lio/vertx/core/http/HttpVersion;
            getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
            if_acmpne 13
        12: .line 291
            aload 1 /* request */
            invokeinterface io.netty.handler.codec.http.HttpRequest.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.vertx.core.http.HttpHeaders.CONNECTION:Ljava/lang/CharSequence;
            getstatic io.vertx.core.http.HttpHeaders.KEEP_ALIVE:Ljava/lang/CharSequence;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
        13: .line 293
      StackMap locals:
      StackMap stack:
            return
        end local 4 // io.netty.handler.codec.http.HttpHeaders headers
        end local 3 // boolean chunked
        end local 2 // java.lang.String hostHeader
        end local 1 // io.netty.handler.codec.http.HttpRequest request
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   14     0        this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   14     1     request  Lio/netty/handler/codec/http/HttpRequest;
            0   14     2  hostHeader  Ljava/lang/String;
            0   14     3     chunked  Z
            1   14     4     headers  Lio/netty/handler/codec/http/HttpHeaders;
    MethodParameters:
            Name  Flags
      request     
      hostHeader  
      chunked     

  private void sendRequest(io.netty.handler.codec.http.HttpRequest, io.netty.buffer.ByteBuf, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=5
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.netty.handler.codec.http.HttpRequest request
        start local 2 // io.netty.buffer.ByteBuf buf
        start local 3 // boolean end
        start local 4 // io.vertx.core.Handler handler
         0: .line 297
            iload 3 /* end */
            ifeq 6
         1: .line 298
            aload 2 /* buf */
            ifnull 4
         2: .line 299
            new io.vertx.core.http.impl.AssembledFullHttpRequest
            dup
            aload 1 /* request */
            aload 2 /* buf */
            invokespecial io.vertx.core.http.impl.AssembledFullHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;)V
            astore 1 /* request */
         3: .line 300
            goto 8
         4: .line 301
      StackMap locals:
      StackMap stack:
            new io.vertx.core.http.impl.AssembledFullHttpRequest
            dup
            aload 1 /* request */
            invokespecial io.vertx.core.http.impl.AssembledFullHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;)V
            astore 1 /* request */
         5: .line 303
            goto 8
         6: .line 304
      StackMap locals:
      StackMap stack:
            aload 2 /* buf */
            ifnull 8
         7: .line 305
            new io.vertx.core.http.impl.AssembledHttpRequest
            dup
            aload 1 /* request */
            aload 2 /* buf */
            invokespecial io.vertx.core.http.impl.AssembledHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;)V
            astore 1 /* request */
         8: .line 308
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 1 /* request */
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 4 /* handler */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.toPromise:(Lio/vertx/core/Handler;)Lio/netty/channel/ChannelPromise;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeToChannel:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
         9: .line 309
            return
        end local 4 // io.vertx.core.Handler handler
        end local 3 // boolean end
        end local 2 // io.netty.buffer.ByteBuf buf
        end local 1 // io.netty.handler.codec.http.HttpRequest request
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   10     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   10     1  request  Lio/netty/handler/codec/http/HttpRequest;
            0   10     2      buf  Lio/netty/buffer/ByteBuf;
            0   10     3      end  Z
            0   10     4  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/netty/handler/codec/http/HttpRequest;Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      request  
      buf      
      end      
      handler  

  private boolean handleChunk(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.buffer.Buffer buff
         0: .line 312
            aload 0 /* this */
            dup
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesRead:J
            aload 1 /* buff */
            invokeinterface io.vertx.core.buffer.Buffer.length:()I
            i2l
            ladd
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesRead:J
         1: .line 313
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 1 /* buff */
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.write:(Ljava/lang/Object;)Z
            ireturn
        end local 1 // io.vertx.core.buffer.Buffer buff
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    2     1  buff  Lio/vertx/core/buffer/Buffer;
    MethodParameters:
      Name  Flags
      buff  

  public void writeBuffer(io.netty.buffer.ByteBuf, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.netty.buffer.ByteBuf buff
        start local 2 // boolean end
        start local 3 // io.vertx.core.Handler handler
         0: .line 318
            aload 1 /* buff */
            ifnonnull 2
            iload 2 /* end */
            ifne 2
         1: .line 319
            return
         2: .line 322
      StackMap locals:
      StackMap stack:
            iload 2 /* end */
            ifeq 8
         3: .line 323
            aload 1 /* buff */
            ifnull 6
            aload 1 /* buff */
            invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
            ifeq 6
         4: .line 324
            new io.netty.handler.codec.http.DefaultLastHttpContent
            dup
            aload 1 /* buff */
            iconst_0
            invokespecial io.netty.handler.codec.http.DefaultLastHttpContent.<init>:(Lio/netty/buffer/ByteBuf;Z)V
            astore 4 /* msg */
        start local 4 // io.netty.handler.codec.http.HttpContent msg
         5: .line 325
            goto 9
        end local 4 // io.netty.handler.codec.http.HttpContent msg
         6: .line 326
      StackMap locals:
      StackMap stack:
            getstatic io.netty.handler.codec.http.LastHttpContent.EMPTY_LAST_CONTENT:Lio/netty/handler/codec/http/LastHttpContent;
            astore 4 /* msg */
        start local 4 // io.netty.handler.codec.http.HttpContent msg
         7: .line 328
            goto 9
        end local 4 // io.netty.handler.codec.http.HttpContent msg
         8: .line 329
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.http.DefaultHttpContent
            dup
            aload 1 /* buff */
            invokespecial io.netty.handler.codec.http.DefaultHttpContent.<init>:(Lio/netty/buffer/ByteBuf;)V
            astore 4 /* msg */
        start local 4 // io.netty.handler.codec.http.HttpContent msg
         9: .line 331
      StackMap locals: io.netty.handler.codec.http.HttpContent
      StackMap stack:
            aload 0 /* this */
            dup
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesWritten:J
            aload 4 /* msg */
            invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            i2l
            ladd
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesWritten:J
        10: .line 332
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 4 /* msg */
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 3 /* handler */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.toPromise:(Lio/vertx/core/Handler;)Lio/netty/channel/ChannelPromise;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeToChannel:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
        11: .line 333
            return
        end local 4 // io.netty.handler.codec.http.HttpContent msg
        end local 3 // io.vertx.core.Handler handler
        end local 2 // boolean end
        end local 1 // io.netty.buffer.ByteBuf buff
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   12     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   12     1     buff  Lio/netty/buffer/ByteBuf;
            0   12     2      end  Z
            0   12     3  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            5    6     4      msg  Lio/netty/handler/codec/http/HttpContent;
            7    8     4      msg  Lio/netty/handler/codec/http/HttpContent;
            9   12     4      msg  Lio/netty/handler/codec/http/HttpContent;
    Signature: (Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      buff     
      end      
      handler  

  public void writeFrame(int, int, io.netty.buffer.ByteBuf);
    descriptor: (IILio/netty/buffer/ByteBuf;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // int type
        start local 2 // int flags
        start local 3 // io.netty.buffer.ByteBuf payload
         0: .line 337
            new java.lang.IllegalStateException
            dup
            ldc "Cannot write an HTTP/2 frame over an HTTP/1.x connection"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        end local 3 // io.netty.buffer.ByteBuf payload
        end local 2 // int flags
        end local 1 // int type
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    1     1     type  I
            0    1     2    flags  I
            0    1     3  payload  Lio/netty/buffer/ByteBuf;
    MethodParameters:
         Name  Flags
      type     
      flags    
      payload  

  public void doSetWriteQueueMaxSize(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // int size
         0: .line 342
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            iload 1 /* size */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.doSetWriteQueueMaxSize:(I)V
         1: .line 343
            return
        end local 1 // int size
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    2     1  size  I
    MethodParameters:
      Name  Flags
      size  

  public boolean isNotWritable();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 347
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.isNotWritable:()Z
            ireturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public void doPause();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 352
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.pause:()Lio/vertx/core/streams/impl/InboundBuffer;
            pop
         1: .line 353
            return
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public void doFetch(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // long amount
         0: .line 357
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            lload 1 /* amount */
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.fetch:(J)Z
            pop
         1: .line 358
            return
        end local 1 // long amount
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    2     1  amount  J
    MethodParameters:
        Name  Flags
      amount  

  public void reset(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // java.lang.Throwable cause
         0: .line 362
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
         1: .line 363
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.reset:Z
            ifeq 4
         2: .line 364
            aload 2
            monitorexit
         3: return
         4: .line 366
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.reset:Z
         5: .line 362
            aload 2
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 2
            monitorexit
         8: athrow
         9: .line 368
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* cause */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.handleException:(Ljava/lang/Throwable;)V
        10: .line 369
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
        11: .line 370
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            aload 0 /* this */
            if_acmpne 17
        12: .line 371
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            ifnonnull 15
        13: .line 373
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            iconst_1
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleRequestEnd:(Z)V
        14: .line 374
            goto 19
        15: .line 375
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()V
        16: .line 377
            goto 19
      StackMap locals:
      StackMap stack:
        17: aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.responseEnded:Z
            ifne 19
        18: .line 378
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.close:()V
        19: .line 369
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
        20: goto 23
      StackMap locals:
      StackMap stack: java.lang.Throwable
        21: aload 2
            monitorexit
        22: athrow
        23: .line 383
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable cause
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   24     0   this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   24     1  cause  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     3       7  any
           4     6       7  any
           7     8       7  any
          11    20      21  any
          21    22      21  any
    MethodParameters:
       Name  Flags
      cause  

  public void beginRequest(io.vertx.core.http.impl.HttpClientRequestImpl);
    descriptor: (Lio/vertx/core/http/impl/HttpClientRequestImpl;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.impl.HttpClientRequestImpl req
         0: .line 387
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
         1: .line 388
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            ifnull 3
         2: .line 389
            new java.lang.IllegalStateException
            dup
            ldc "Already writing a request"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 391
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            aload 0 /* this */
            if_acmpeq 5
         4: .line 392
            new java.lang.IllegalStateException
            dup
            ldc "Connection is already writing another request"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         5: .line 394
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* req */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
         6: .line 395
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 8
         7: .line 396
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.endpointMetric:Ljava/lang/Object;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.metric:()Ljava/lang/Object;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.localAddress:()Lio/vertx/core/net/SocketAddress;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.remoteAddress:()Lio/vertx/core/net/SocketAddress;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.requestBegin:(Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/http/HttpClientRequest;)Ljava/lang/Object;
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.metric:Ljava/lang/Object;
         8: .line 387
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
         9: goto 12
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: aload 2
            monitorexit
        11: athrow
        12: .line 399
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.http.impl.HttpClientRequestImpl req
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   13     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   13     1   req  Lio/vertx/core/http/impl/HttpClientRequestImpl;
      Exception table:
        from    to  target  type
           1     9      10  any
          10    11      10  any
    MethodParameters:
      Name  Flags
      req   

  public void endRequest();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 403
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
         1: .line 404
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.requestInProgress:Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            astore 3 /* s */
        start local 3 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl s
         2: .line 405
            aload 3 /* s */
            aload 0 /* this */
            if_acmpeq 4
         3: .line 406
            new java.lang.IllegalStateException
            dup
            ldc "No write in progress"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 408
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl top io.vertx.core.http.impl.Http1xClientConnection io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.requestEnded:Z
            ifeq 6
         5: .line 409
            new java.lang.IllegalStateException
            dup
            ldc "Request already sent"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 411
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.requestEnded:Z
         7: .line 412
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 9
         8: .line 413
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.metric:Ljava/lang/Object;
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.requestEnd:(Ljava/lang/Object;)V
         9: .line 415
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.responseEnded:Z
            istore 1 /* doRecycle */
        end local 3 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl s
        start local 1 // boolean doRecycle
        10: .line 403
            aload 2
            monitorexit
        11: goto 14
        end local 1 // boolean doRecycle
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl top io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack: java.lang.Throwable
        12: aload 2
            monitorexit
        13: athrow
        start local 1 // boolean doRecycle
        14: .line 417
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl int
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesWritten:J
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.reportBytesWritten:(J)V
        15: .line 418
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            iload 1 /* doRecycle */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.handleRequestEnd:(Z)V
        16: .line 419
            return
        end local 1 // boolean doRecycle
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   17     0       this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
           10   12     1  doRecycle  Z
           14   17     1  doRecycle  Z
            2   10     3          s  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
      Exception table:
        from    to  target  type
           1    11      12  any
          12    13      12  any

  public io.vertx.core.net.NetSocket createNetSocket();
    descriptor: ()Lio/vertx/core/net/NetSocket;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 423
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 1
            monitorenter
         1: .line 424
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.responseEnded:Z
            ifeq 3
         2: .line 425
            new java.lang.IllegalStateException
            dup
            ldc "Response already ended"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 427
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 0 /* this */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.upgrade:(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)Lio/vertx/core/net/NetSocket;
            aload 1
            monitorexit
         4: areturn
         5: .line 423
      StackMap locals:
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         6: athrow
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any

  public io.vertx.core.http.StreamPriority priority();
    descriptor: ()Lio/vertx/core/http/StreamPriority;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 433
            aconst_null
            areturn
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;

  public void updatePriority(io.vertx.core.http.StreamPriority);
    descriptor: (Lio/vertx/core/http/StreamPriority;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=0, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.StreamPriority streamPriority
         0: .line 438
            return
        end local 1 // io.vertx.core.http.StreamPriority streamPriority
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    1     0            this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    1     1  streamPriority  Lio/vertx/core/http/StreamPriority;
    MethodParameters:
                Name  Flags
      streamPriority  

  private io.vertx.core.http.impl.HttpClientResponseImpl beginResponse(io.netty.handler.codec.http.HttpResponse);
    descriptor: (Lio/netty/handler/codec/http/HttpResponse;)Lio/vertx/core/http/impl/HttpClientResponseImpl;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=11, locals=8, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.netty.handler.codec.http.HttpResponse resp
         0: .line 442
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
            getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_0:Lio/netty/handler/codec/http/HttpVersion;
            if_acmpne 3
         1: .line 443
            getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
            astore 2 /* version */
        start local 2 // io.vertx.core.http.HttpVersion version
         2: .line 444
            goto 4
        end local 2 // io.vertx.core.http.HttpVersion version
         3: .line 445
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.core.http.HttpVersion.HTTP_1_1:Lio/vertx/core/http/HttpVersion;
            astore 2 /* version */
        start local 2 // io.vertx.core.http.HttpVersion version
         4: .line 447
      StackMap locals: io.vertx.core.http.HttpVersion
      StackMap stack:
            aload 0 /* this */
            new io.vertx.core.http.impl.HttpClientResponseImpl
            dup
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            aload 2 /* version */
            aload 0 /* this */
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
            invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
            invokevirtual io.netty.handler.codec.http.HttpResponseStatus.reasonPhrase:()Ljava/lang/String;
            new io.vertx.core.http.impl.HeadersAdaptor
            dup
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            invokespecial io.vertx.core.http.impl.HeadersAdaptor.<init>:(Lio/netty/handler/codec/http/HttpHeaders;)V
            invokespecial io.vertx.core.http.impl.HttpClientResponseImpl.<init>:(Lio/vertx/core/http/impl/HttpClientRequestBase;Lio/vertx/core/http/HttpVersion;Lio/vertx/core/http/impl/HttpClientStream;ILjava/lang/String;Lio/vertx/core/MultiMap;)V
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
         5: .line 448
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 7
         6: .line 449
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.metric:Ljava/lang/Object;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.responseBegin:(Ljava/lang/Object;Lio/vertx/core/http/HttpClientResponse;)V
         7: .line 451
      StackMap locals:
      StackMap stack:
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
            invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
            bipush 100
            if_icmpeq 21
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.method:()Lio/vertx/core/http/HttpMethod;
            getstatic io.vertx.core.http.HttpMethod.CONNECT:Lio/vertx/core/http/HttpMethod;
            if_acmpeq 21
         8: .line 453
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.netty.handler.codec.http.HttpHeaderNames.CONNECTION:Lio/netty/util/AsciiString;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
            astore 3 /* responseConnectionHeader */
        start local 3 // java.lang.String responseConnectionHeader
         9: .line 454
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
            astore 4 /* protocolVersion */
        start local 4 // io.netty.handler.codec.http.HttpVersion protocolVersion
        10: .line 455
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.headers:()Lio/vertx/core/MultiMap;
            getstatic io.netty.handler.codec.http.HttpHeaderNames.CONNECTION:Lio/netty/util/AsciiString;
            invokeinterface io.vertx.core.MultiMap.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
            astore 5 /* requestConnectionHeader */
        start local 5 // java.lang.String requestConnectionHeader
        11: .line 457
            getstatic io.netty.handler.codec.http.HttpHeaderValues.CLOSE:Lio/netty/util/AsciiString;
            aload 3 /* responseConnectionHeader */
            invokevirtual io.netty.util.AsciiString.contentEqualsIgnoreCase:(Ljava/lang/CharSequence;)Z
            ifne 12
            getstatic io.netty.handler.codec.http.HttpHeaderValues.CLOSE:Lio/netty/util/AsciiString;
            aload 5 /* requestConnectionHeader */
            invokevirtual io.netty.util.AsciiString.contentEqualsIgnoreCase:(Ljava/lang/CharSequence;)Z
            ifeq 14
        12: .line 459
      StackMap locals: java.lang.String io.netty.handler.codec.http.HttpVersion java.lang.String
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            iconst_1
            putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
        13: .line 460
            goto 16
      StackMap locals:
      StackMap stack:
        14: aload 4 /* protocolVersion */
            getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_0:Lio/netty/handler/codec/http/HttpVersion;
            if_acmpne 16
            getstatic io.netty.handler.codec.http.HttpHeaderValues.KEEP_ALIVE:Lio/netty/util/AsciiString;
            aload 3 /* responseConnectionHeader */
            invokevirtual io.netty.util.AsciiString.contentEqualsIgnoreCase:(Ljava/lang/CharSequence;)Z
            ifne 16
        15: .line 463
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            iconst_1
            putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
        16: .line 465
      StackMap locals:
      StackMap stack:
            aload 1 /* resp */
            invokeinterface io.netty.handler.codec.http.HttpResponse.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.netty.handler.codec.http.HttpHeaderNames.KEEP_ALIVE:Lio/netty/util/AsciiString;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
            astore 6 /* keepAliveHeader */
        start local 6 // java.lang.String keepAliveHeader
        17: .line 466
            aload 6 /* keepAliveHeader */
            ifnull 21
        18: .line 467
            aload 6 /* keepAliveHeader */
            invokestatic io.vertx.core.http.impl.HttpUtils.parseKeepAliveHeaderTimeout:(Ljava/lang/CharSequence;)I
            istore 7 /* timeout */
        start local 7 // int timeout
        19: .line 468
            iload 7 /* timeout */
            iconst_m1
            if_icmpeq 21
        20: .line 469
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            iload 7 /* timeout */
            putfield io.vertx.core.http.impl.Http1xClientConnection.keepAliveTimeout:I
        end local 7 // int timeout
        end local 6 // java.lang.String keepAliveHeader
        end local 5 // java.lang.String requestConnectionHeader
        end local 4 // io.netty.handler.codec.http.HttpVersion protocolVersion
        end local 3 // java.lang.String responseConnectionHeader
        21: .line 473
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)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/Http1xClientConnection$StreamImpl.lambda$0(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
        22: .line 481
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)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/Http1xClientConnection$StreamImpl.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
        23: .line 486
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
            areturn
        end local 2 // io.vertx.core.http.HttpVersion version
        end local 1 // io.netty.handler.codec.http.HttpResponse resp
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0   24     0                      this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   24     1                      resp  Lio/netty/handler/codec/http/HttpResponse;
            2    3     2                   version  Lio/vertx/core/http/HttpVersion;
            4   24     2                   version  Lio/vertx/core/http/HttpVersion;
            9   21     3  responseConnectionHeader  Ljava/lang/String;
           10   21     4           protocolVersion  Lio/netty/handler/codec/http/HttpVersion;
           11   21     5   requestConnectionHeader  Ljava/lang/String;
           17   21     6           keepAliveHeader  Ljava/lang/String;
           19   21     7                   timeout  I
    MethodParameters:
      Name  Flags
      resp  

  private boolean endResponse(io.netty.handler.codec.http.LastHttpContent);
    descriptor: (Lio/netty/handler/codec/http/LastHttpContent;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.netty.handler.codec.http.LastHttpContent trailer
         0: .line 490
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
         1: .line 491
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            ifnull 3
         2: .line 492
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.metrics:Lio/vertx/core/spi/metrics/HttpClientMetrics;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.metric:Ljava/lang/Object;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
            invokeinterface io.vertx.core.spi.metrics.HttpClientMetrics.responseEnd:(Ljava/lang/Object;Lio/vertx/core/http/HttpClientResponse;)V
         3: .line 490
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 495
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            new io.vertx.core.http.impl.HeadersAdaptor
            dup
            aload 1 /* trailer */
            invokeinterface io.netty.handler.codec.http.LastHttpContent.trailingHeaders:()Lio/netty/handler/codec/http/HttpHeaders;
            invokespecial io.vertx.core.http.impl.HeadersAdaptor.<init>:(Lio/netty/handler/codec/http/HttpHeaders;)V
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.write:(Ljava/lang/Object;)Z
            pop
         8: .line 496
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
         9: .line 497
            aload 0 /* this */
            iconst_1
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.responseEnded:Z
        10: .line 498
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            getfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            getfield io.vertx.core.http.impl.Http1xClientConnection.options:Lio/vertx/core/http/HttpClientOptions;
            invokevirtual io.vertx.core.http.HttpClientOptions.isKeepAlive:()Z
            ifeq 11
            iconst_0
            goto 12
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.netty.handler.codec.http.LastHttpContent io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack: io.vertx.core.http.impl.Http1xClientConnection int
        11: iconst_1
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.netty.handler.codec.http.LastHttpContent io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack: io.vertx.core.http.impl.Http1xClientConnection int int
        12: ior
            putfield io.vertx.core.http.impl.Http1xClientConnection.close:Z
        13: .line 499
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.doResume:()V
        14: .line 500
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.requestEnded:Z
            aload 2
            monitorexit
        15: ireturn
        16: .line 496
      StackMap locals:
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
        17: athrow
        end local 1 // io.netty.handler.codec.http.LastHttpContent trailer
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   18     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   18     1  trailer  Lio/netty/handler/codec/http/LastHttpContent;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
           9    15      16  any
          16    17      16  any
    MethodParameters:
         Name  Flags
      trailer  

  void handleException(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=7, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // java.lang.Throwable cause
         0: .line 509
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 6
            monitorenter
         1: .line 510
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpClientRequestImpl;
            astore 2 /* request */
        start local 2 // io.vertx.core.http.impl.HttpClientRequestImpl request
         2: .line 511
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
            astore 3 /* response */
        start local 3 // io.vertx.core.http.impl.HttpClientResponseImpl response
         3: .line 512
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.fut:Lio/vertx/core/Promise;
            astore 4 /* fut */
        start local 4 // io.vertx.core.Promise fut
         4: .line 513
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.requestEnded:Z
            istore 5 /* requestEnded */
        start local 5 // boolean requestEnded
         5: .line 509
            aload 6
            monitorexit
         6: goto 9
        end local 5 // boolean requestEnded
        end local 4 // io.vertx.core.Promise fut
        end local 3 // io.vertx.core.http.impl.HttpClientResponseImpl response
        end local 2 // io.vertx.core.http.impl.HttpClientRequestImpl request
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl java.lang.Throwable top top top top io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack: java.lang.Throwable
         7: aload 6
            monitorexit
         8: athrow
        start local 2 // io.vertx.core.http.impl.HttpClientRequestImpl request
        start local 3 // io.vertx.core.http.impl.HttpClientResponseImpl response
        start local 4 // io.vertx.core.Promise fut
        start local 5 // boolean requestEnded
         9: .line 515
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl java.lang.Throwable io.vertx.core.http.impl.HttpClientRequestImpl io.vertx.core.http.impl.HttpClientResponseImpl io.vertx.core.Promise int
      StackMap stack:
            aload 2 /* request */
            ifnull 17
        10: .line 516
            aload 3 /* response */
            ifnonnull 13
        11: .line 517
            aload 2 /* request */
            aload 1 /* cause */
            invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleException:(Ljava/lang/Throwable;)V
        12: .line 518
            goto 18
        13: .line 519
      StackMap locals:
      StackMap stack:
            iload 5 /* requestEnded */
            ifne 15
        14: .line 520
            aload 2 /* request */
            aload 1 /* cause */
            invokevirtual io.vertx.core.http.impl.HttpClientRequestImpl.handleException:(Ljava/lang/Throwable;)V
        15: .line 522
      StackMap locals:
      StackMap stack:
            aload 3 /* response */
            aload 1 /* cause */
            invokevirtual io.vertx.core.http.impl.HttpClientResponseImpl.handleException:(Ljava/lang/Throwable;)V
        16: .line 524
            goto 18
        17: .line 525
      StackMap locals:
      StackMap stack:
            aload 4 /* fut */
            aload 1 /* cause */
            invokeinterface io.vertx.core.Promise.tryFail:(Ljava/lang/Throwable;)Z
            pop
        18: .line 527
      StackMap locals:
      StackMap stack:
            return
        end local 5 // boolean requestEnded
        end local 4 // io.vertx.core.Promise fut
        end local 3 // io.vertx.core.http.impl.HttpClientResponseImpl response
        end local 2 // io.vertx.core.http.impl.HttpClientRequestImpl request
        end local 1 // java.lang.Throwable cause
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   19     0          this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   19     1         cause  Ljava/lang/Throwable;
            2    7     2       request  Lio/vertx/core/http/impl/HttpClientRequestImpl;
            9   19     2       request  Lio/vertx/core/http/impl/HttpClientRequestImpl;
            3    7     3      response  Lio/vertx/core/http/impl/HttpClientResponseImpl;
            9   19     3      response  Lio/vertx/core/http/impl/HttpClientResponseImpl;
            4    7     4           fut  Lio/vertx/core/Promise<Lio/vertx/core/http/impl/HttpClientStream;>;
            9   19     4           fut  Lio/vertx/core/Promise<Lio/vertx/core/http/impl/HttpClientStream;>;
            5    7     5  requestEnded  Z
            9   19     5  requestEnded  Z
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any
    MethodParameters:
       Name  Flags
      cause  

  public io.vertx.core.http.HttpConnection connection();
    descriptor: ()Lio/vertx/core/http/HttpConnection;
    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.http.impl.Http1xClientConnection$StreamImpl.connection:()Lio/vertx/core/http/impl/HttpClientConnection;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void lambda$0(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // java.lang.Object item
         0: .line 474
            aload 1 /* item */
            instanceof io.vertx.core.MultiMap
            ifeq 4
         1: .line 475
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.bytesRead:J
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.reportBytesRead:(J)V
         2: .line 476
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
            aload 1 /* item */
            checkcast io.vertx.core.MultiMap
            invokevirtual io.vertx.core.http.impl.HttpClientResponseImpl.handleEnd:(Lio/vertx/core/MultiMap;)V
         3: .line 477
            goto 5
         4: .line 478
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.response:Lio/vertx/core/http/impl/HttpClientResponseImpl;
            aload 1 /* item */
            checkcast io.vertx.core.buffer.Buffer
            invokevirtual io.vertx.core.http.impl.HttpClientResponseImpl.handleChunk:(Lio/vertx/core/buffer/Buffer;)V
         5: .line 480
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object item
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    6     1  item  Ljava/lang/Object;

  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.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // java.lang.Void v
         0: .line 482
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.responseEnded:Z
            ifne 2
         1: .line 483
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.doResume:()V
         2: .line 485
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Void v
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    3     1     v  Ljava/lang/Void;
}
SourceFile: "Http1xClientConnection.java"
NestHost: io.vertx.core.http.impl.Http1xClientConnection
InnerClasses:
  private StreamImpl = io.vertx.core.http.impl.Http1xClientConnection$StreamImpl of io.vertx.core.http.impl.Http1xClientConnection
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract Entry = java.util.Map$Entry of java.util.Map