io.vertx/vertx-core/4.0.0 : io/vertx/core/http/impl/Http1xClientConnection$StreamImpl.class

Http1xClientConnection$StreamImpl
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-core: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
class io.vertx.core.http.impl.Http1xClientConnection$StreamImpl extends io.vertx.core.http.impl.Http1xClientConnection$Stream 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: io.vertx.core.http.impl.Http1xClientConnection$Stream
{
  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.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 boolean reset;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

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

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

  private io.vertx.core.Handler<io.vertx.core.http.impl.HttpResponseHead> headHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/vertx/core/http/impl/HttpResponseHead;>;

  private io.vertx.core.Handler<io.vertx.core.buffer.Buffer> chunkHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;

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

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

  private io.vertx.core.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.Handler<java.lang.Throwable> exceptionHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;

  void <init>(io.vertx.core.impl.ContextInternal, io.vertx.core.http.impl.Http1xClientConnection, int);
    descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/http/impl/Http1xClientConnection;I)V
    flags: (0x0000) 
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.impl.ContextInternal context
        start local 2 // io.vertx.core.http.impl.Http1xClientConnection conn
        start local 3 // int id
         0: .line 331
            aload 0 /* this */
            aload 1 /* context */
            iload 3 /* id */
            invokespecial io.vertx.core.http.impl.Http1xClientConnection$Stream.<init>:(Lio/vertx/core/impl/ContextInternal;I)V
         1: .line 333
            aload 0 /* this */
            aload 2 /* conn */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.isNotWritable:()Z
            ifeq 2
            iconst_0
            goto 3
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.impl.ContextInternal io.vertx.core.http.impl.Http1xClientConnection int
      StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl
         2: iconst_1
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.impl.ContextInternal io.vertx.core.http.impl.Http1xClientConnection int
      StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl int
         3: putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writable:Z
         4: .line 334
            aload 0 /* this */
            aload 2 /* conn */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
         5: .line 335
            aload 0 /* this */
            new io.vertx.core.streams.impl.InboundBuffer
            dup
            aload 1 /* context */
            ldc 5
            invokespecial io.vertx.core.streams.impl.InboundBuffer.<init>:(Lio/vertx/core/Context;J)V
         6: .line 336
            aload 0 /* this */
            aload 2 /* conn */
            invokedynamic handle(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;Lio/vertx/core/http/impl/Http1xClientConnection;)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(Lio/vertx/core/http/impl/Http1xClientConnection;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;
         7: .line 344
            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$2(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;
         8: .line 357
            aload 1 /* context */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic handle(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/impl/ContextInternal.reportException(Ljava/lang/Throwable;)V (9 itf)
                  (Ljava/lang/Throwable;)V
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/impl/InboundBuffer;
         9: .line 335
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
        10: .line 358
            return
        end local 3 // int id
        end local 2 // io.vertx.core.http.impl.Http1xClientConnection conn
        end local 1 // io.vertx.core.impl.ContextInternal context
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   11     1  context  Lio/vertx/core/impl/ContextInternal;
            0   11     2     conn  Lio/vertx/core/http/impl/Http1xClientConnection;
            0   11     3       id  I
    MethodParameters:
         Name  Flags
      context  
      conn     
      id       

  private void drained();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 361
            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.drainResponse:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
         1: .line 362
            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 continueHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 366
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.continueHandler:Lio/vertx/core/Handler;
         1: .line 367
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void drainHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 371
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.drainHandler:Lio/vertx/core/Handler;
         1: .line 372
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;)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 // io.vertx.core.Handler handler
         0: .line 376
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.exceptionHandler:Lio/vertx/core/Handler;
         1: .line 377
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void headHandler(io.vertx.core.Handler<io.vertx.core.http.impl.HttpResponseHead>);
    descriptor: (Lio/vertx/core/Handler;)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 // io.vertx.core.Handler handler
         0: .line 381
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.headHandler:Lio/vertx/core/Handler;
         1: .line 382
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Lio/vertx/core/http/impl/HttpResponseHead;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/impl/HttpResponseHead;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void priorityHandler(io.vertx.core.Handler<io.vertx.core.http.StreamPriority>);
    descriptor: (Lio/vertx/core/Handler;)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.Handler handler
         0: .line 387
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Lio/vertx/core/http/StreamPriority;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/StreamPriority;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void pushHandler(io.vertx.core.Handler<io.vertx.core.http.impl.HttpClientPush>);
    descriptor: (Lio/vertx/core/Handler;)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.Handler handler
         0: .line 392
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Lio/vertx/core/http/impl/HttpClientPush;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/impl/HttpClientPush;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void unknownFrameHandler(io.vertx.core.Handler<io.vertx.core.http.HttpFrame>);
    descriptor: (Lio/vertx/core/Handler;)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.Handler handler
         0: .line 397
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Lio/vertx/core/http/HttpFrame;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpFrame;>;)V
    MethodParameters:
         Name  Flags
      handler  

  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 401
            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 406
            aload 0 /* this */
            invokespecial io.vertx.core.http.impl.Http1xClientConnection$Stream.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 411
            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 416
            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.impl.ContextInternal getContext();
    descriptor: ()Lio/vertx/core/impl/ContextInternal;
    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 421
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.context: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.impl.HttpRequestHead, boolean, io.netty.buffer.ByteBuf, boolean, io.vertx.core.http.StreamPriority, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZLio/vertx/core/http/StreamPriority;ZLio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=8, args_size=8
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.impl.HttpRequestHead request
        start local 2 // boolean chunked
        start local 3 // io.netty.buffer.ByteBuf buf
        start local 4 // boolean end
        start local 5 // io.vertx.core.http.StreamPriority priority
        start local 6 // boolean connect
        start local 7 // io.vertx.core.Handler handler
         0: .line 426
            aload 0 /* this */
            aload 1 /* request */
            iload 2 /* chunked */
            aload 3 /* buf */
            iload 4 /* end */
            iload 6 /* connect */
            aload 7 /* handler */
            ifnonnull 1
            aconst_null
            goto 2
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int io.vertx.core.http.StreamPriority int io.vertx.core.Handler
      StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int int
         1: aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.context:Lio/vertx/core/impl/ContextInternal;
            aload 7 /* handler */
            invokeinterface io.vertx.core.impl.ContextInternal.promise:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int io.vertx.core.http.StreamPriority int io.vertx.core.Handler
      StackMap stack: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl io.vertx.core.http.impl.HttpRequestHead int io.netty.buffer.ByteBuf int int io.vertx.core.impl.future.PromiseInternal
         2: invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writeHead:(Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
         3: .line 427
            return
        end local 7 // io.vertx.core.Handler handler
        end local 6 // boolean connect
        end local 5 // io.vertx.core.http.StreamPriority priority
        end local 4 // boolean end
        end local 3 // io.netty.buffer.ByteBuf buf
        end local 2 // boolean chunked
        end local 1 // io.vertx.core.http.impl.HttpRequestHead request
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    4     1   request  Lio/vertx/core/http/impl/HttpRequestHead;
            0    4     2   chunked  Z
            0    4     3       buf  Lio/netty/buffer/ByteBuf;
            0    4     4       end  Z
            0    4     5  priority  Lio/vertx/core/http/StreamPriority;
            0    4     6   connect  Z
            0    4     7   handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZLio/vertx/core/http/StreamPriority;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
          Name  Flags
      request   
      chunked   
      buf       
      end       
      priority  
      connect   
      handler   

  private void writeHead(io.vertx.core.http.impl.HttpRequestHead, boolean, io.netty.buffer.ByteBuf, boolean, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=8, locals=8, args_size=7
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.impl.HttpRequestHead request
        start local 2 // boolean chunked
        start local 3 // io.netty.buffer.ByteBuf buf
        start local 4 // boolean end
        start local 5 // boolean connect
        start local 6 // io.vertx.core.Handler handler
         0: .line 430
            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$15:(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.nettyEventLoop:()Lio/netty/channel/EventLoop;
            astore 7 /* eventLoop */
        start local 7 // io.netty.channel.EventLoop eventLoop
         1: .line 431
            aload 7 /* eventLoop */
            invokeinterface io.netty.channel.EventLoop.inEventLoop:()Z
            ifeq 5
         2: .line 432
            aload 0 /* this */
            aload 1 /* request */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.request:Lio/vertx/core/http/impl/HttpRequestHead;
         3: .line 433
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 0 /* this */
            aload 1 /* request */
            iload 2 /* chunked */
            aload 3 /* buf */
            iload 4 /* end */
            iload 5 /* connect */
            aload 6 /* handler */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.beginRequest:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
         4: .line 434
            goto 6
         5: .line 435
      StackMap locals: io.netty.channel.EventLoop
      StackMap stack:
            aload 7 /* eventLoop */
            aload 0 /* this */
            aload 1 /* request */
            iload 2 /* chunked */
            aload 3 /* buf */
            iload 4 /* end */
            iload 5 /* connect */
            aload 6 /* handler */
            invokedynamic run(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)Ljava/lang/Runnable;
              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:
                  ()V
                  io/vertx/core/http/impl/Http1xClientConnection$StreamImpl.lambda$4(Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V (7)
                  ()V
            invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
         6: .line 437
      StackMap locals:
      StackMap stack:
            return
        end local 7 // io.netty.channel.EventLoop eventLoop
        end local 6 // io.vertx.core.Handler handler
        end local 5 // boolean connect
        end local 4 // boolean end
        end local 3 // io.netty.buffer.ByteBuf buf
        end local 2 // boolean chunked
        end local 1 // io.vertx.core.http.impl.HttpRequestHead request
        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    request  Lio/vertx/core/http/impl/HttpRequestHead;
            0    7     2    chunked  Z
            0    7     3        buf  Lio/netty/buffer/ByteBuf;
            0    7     4        end  Z
            0    7     5    connect  Z
            0    7     6    handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1    7     7  eventLoop  Lio/netty/channel/EventLoop;
    Signature: (Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      request  
      chunked  
      buf      
      end      
      connect  
      handler  

  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=4, 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 441
            aload 1 /* buff */
            ifnonnull 1
            iload 2 /* end */
            ifeq 5
         1: .line 442
      StackMap locals:
      StackMap stack:
            aload 3 /* handler */
            ifnonnull 2
            aconst_null
            goto 3
      StackMap locals:
      StackMap stack:
         2: aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.context:Lio/vertx/core/impl/ContextInternal;
            aload 3 /* handler */
            invokeinterface io.vertx.core.impl.ContextInternal.promise:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
      StackMap locals:
      StackMap stack: io.vertx.core.impl.future.PromiseInternal
         3: astore 4 /* listener */
        start local 4 // io.netty.util.concurrent.FutureListener listener
         4: .line 443
            aload 0 /* this */
            aload 1 /* buff */
            iload 2 /* end */
            aload 4 /* listener */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writeBuffer:(Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V
        end local 4 // io.netty.util.concurrent.FutureListener listener
         5: .line 445
      StackMap locals:
      StackMap stack:
            return
        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    6     0      this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    6     1      buff  Lio/netty/buffer/ByteBuf;
            0    6     2       end  Z
            0    6     3   handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            4    5     4  listener  Lio/netty/util/concurrent/FutureListener<Ljava/lang/Void;>;
    Signature: (Lio/netty/buffer/ByteBuf;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      buff     
      end      
      handler  

  private void writeBuffer(io.netty.buffer.ByteBuf, boolean, io.netty.util.concurrent.FutureListener<java.lang.Void>);
    descriptor: (Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V
    flags: (0x0002) ACC_PRIVATE
    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.netty.util.concurrent.FutureListener listener
         0: .line 448
            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$15:(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.nettyEventLoop:()Lio/netty/channel/EventLoop;
            astore 4 /* eventLoop */
        start local 4 // io.netty.channel.EventLoop eventLoop
         1: .line 449
            aload 4 /* eventLoop */
            invokeinterface io.netty.channel.EventLoop.inEventLoop:()Z
            ifeq 4
         2: .line 450
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            aload 0 /* this */
            aload 1 /* buff */
            iload 2 /* end */
            aload 3 /* listener */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection.writeBuffer:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V
         3: .line 451
            goto 5
         4: .line 452
      StackMap locals: io.netty.channel.EventLoop
      StackMap stack:
            aload 4 /* eventLoop */
            aload 0 /* this */
            aload 1 /* buff */
            iload 2 /* end */
            aload 3 /* listener */
            invokedynamic run(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)Ljava/lang/Runnable;
              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:
                  ()V
                  io/vertx/core/http/impl/Http1xClientConnection$StreamImpl.lambda$5(Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V (7)
                  ()V
            invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
         5: .line 454
      StackMap locals:
      StackMap stack:
            return
        end local 4 // io.netty.channel.EventLoop eventLoop
        end local 3 // io.netty.util.concurrent.FutureListener listener
        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    6     0       this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    6     1       buff  Lio/netty/buffer/ByteBuf;
            0    6     2        end  Z
            0    6     3   listener  Lio/netty/util/concurrent/FutureListener<Ljava/lang/Void;>;
            1    6     4  eventLoop  Lio/netty/channel/EventLoop;
    Signature: (Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener<Ljava/lang/Void;>;)V
    MethodParameters:
          Name  Flags
      buff      
      end       
      listener  

  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 458
            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 463
            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 464
            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=2, locals=2, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 468
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 1
            monitorenter
         1: .line 469
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writable:Z
            ifeq 2
            iconst_0
            goto 3
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
         2: iconst_1
      StackMap locals:
      StackMap stack: int
         3: aload 1
            monitorexit
         4: ireturn
         5: .line 468
      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 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 475
            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 476
            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 480
            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 481
            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 485
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 2
            monitorenter
         1: .line 486
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.reset:Z
            ifeq 4
         2: .line 487
            aload 2
            monitorexit
         3: return
         4: .line 489
      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 485
            aload 2
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 2
            monitorexit
         8: athrow
         9: .line 491
      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 492
            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$15:(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.nettyEventLoop:()Lio/netty/channel/EventLoop;
            astore 2 /* eventLoop */
        start local 2 // io.netty.channel.EventLoop eventLoop
        11: .line 493
            aload 2 /* eventLoop */
            invokeinterface io.netty.channel.EventLoop.inEventLoop:()Z
            ifeq 14
        12: .line 494
            aload 0 /* this */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.reset:()V
        13: .line 495
            goto 15
        14: .line 496
      StackMap locals: io.netty.channel.EventLoop
      StackMap stack:
            aload 2 /* eventLoop */
            aload 0 /* this */
            invokedynamic run(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)Ljava/lang/Runnable;
              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:
                  ()V
                  io/vertx/core/http/impl/Http1xClientConnection$StreamImpl.reset()V (7)
                  ()V
            invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
        15: .line 498
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.netty.channel.EventLoop eventLoop
        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   16     0       this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0   16     1      cause  Ljava/lang/Throwable;
           11   16     2  eventLoop  Lio/netty/channel/EventLoop;
      Exception table:
        from    to  target  type
           1     3       7  any
           4     6       7  any
           7     8       7  any
    MethodParameters:
       Name  Flags
      cause  

  private void reset();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 501
            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.resetRequest:(Lio/vertx/core/http/impl/Http1xClientConnection$Stream;)V
         1: .line 502
            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 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 506
            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 511
            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  

  void handleWritabilityChanged(boolean);
    descriptor: (Z)V
    flags: (0x0000) 
    Code:
      stack=2, locals=5, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // boolean writable
         0: .line 517
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.conn:Lio/vertx/core/http/impl/Http1xClientConnection;
            dup
            astore 4
            monitorenter
         1: .line 518
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writable:Z
            ifne 2
            iload 1 /* writable */
            ifeq 2
            iconst_1
            goto 3
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl int top top io.vertx.core.http.impl.Http1xClientConnection
      StackMap stack:
         2: iconst_0
      StackMap locals:
      StackMap stack: int
         3: istore 3 /* drain */
        start local 3 // boolean drain
         4: .line 519
            aload 0 /* this */
            iload 1 /* writable */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writable:Z
         5: .line 520
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.drainHandler:Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         6: .line 517
            aload 4
            monitorexit
         7: goto 10
        end local 3 // boolean drain
        end local 2 // io.vertx.core.Handler handler
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: aload 4
            monitorexit
         9: athrow
        start local 2 // io.vertx.core.Handler handler
        start local 3 // boolean drain
        10: .line 522
      StackMap locals: io.vertx.core.http.impl.Http1xClientConnection$StreamImpl int io.vertx.core.Handler int
      StackMap stack:
            iload 3 /* drain */
            ifeq 12
            aload 2 /* handler */
            ifnull 12
        11: .line 523
            aload 2 /* handler */
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        12: .line 525
      StackMap locals:
      StackMap stack:
            return
        end local 3 // boolean drain
        end local 2 // io.vertx.core.Handler handler
        end local 1 // boolean writable
        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  writable  Z
            6    8     2   handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
           10   13     2   handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
            4    8     3     drain  Z
           10   13     3     drain  Z
      Exception table:
        from    to  target  type
           1     7       8  any
           8     9       8  any
    MethodParameters:
          Name  Flags
      writable  

  void handleContinue();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 528
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.continueHandler:Lio/vertx/core/Handler;
            ifnull 2
         1: .line 529
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.continueHandler:Lio/vertx/core/Handler;
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         2: .line 531
      StackMap locals:
      StackMap stack:
            return
        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;

  void handleHead(io.vertx.core.http.impl.HttpResponseHead);
    descriptor: (Lio/vertx/core/http/impl/HttpResponseHead;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // io.vertx.core.http.impl.HttpResponseHead response
         0: .line 535
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.headHandler:Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         1: .line 536
            aload 2 /* handler */
            ifnull 3
         2: .line 537
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.context:Lio/vertx/core/impl/ContextInternal;
            aload 1 /* response */
            aload 2 /* handler */
            invokeinterface io.vertx.core.impl.ContextInternal.emit:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
         3: .line 539
      StackMap locals: io.vertx.core.Handler
      StackMap stack:
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // io.vertx.core.http.impl.HttpResponseHead response
        end local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    4     1  response  Lio/vertx/core/http/impl/HttpResponseHead;
            1    4     2   handler  Lio/vertx/core/Handler<Lio/vertx/core/http/impl/HttpResponseHead;>;
    MethodParameters:
          Name  Flags
      response  

  public void chunkHandler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
    descriptor: (Lio/vertx/core/Handler;)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 // io.vertx.core.Handler handler
         0: .line 543
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.chunkHandler:Lio/vertx/core/Handler;
         1: .line 544
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void endHandler(io.vertx.core.Handler<io.vertx.core.MultiMap>);
    descriptor: (Lio/vertx/core/Handler;)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 // io.vertx.core.Handler handler
         0: .line 548
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.endHandler:Lio/vertx/core/Handler;
         1: .line 549
            return
        end local 1 // io.vertx.core.Handler handler
        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  handler  Lio/vertx/core/Handler<Lio/vertx/core/MultiMap;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/MultiMap;>;)V
    MethodParameters:
         Name  Flags
      handler  

  void handleChunk(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)V
    flags: (0x0000) 
    Code:
      stack=2, 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 552
            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
            ifne 2
         1: .line 553
            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.doPause:()V
         2: .line 555
      StackMap locals:
      StackMap stack:
            return
        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    3     0  this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    3     1  buff  Lio/vertx/core/buffer/Buffer;
    MethodParameters:
      Name  Flags
      buff  

  void handleEnd(io.netty.handler.codec.http.LastHttpContent);
    descriptor: (Lio/netty/handler/codec/http/LastHttpContent;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=2, 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 558
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.queue:Lio/vertx/core/streams/impl/InboundBuffer;
            new io.vertx.core.http.impl.headers.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.headers.HeadersAdaptor.<init>:(Lio/netty/handler/codec/http/HttpHeaders;)V
            invokevirtual io.vertx.core.streams.impl.InboundBuffer.write:(Ljava/lang/Object;)Z
            pop
         1: .line 559
            return
        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    2     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    2     1  trailer  Lio/netty/handler/codec/http/LastHttpContent;
    MethodParameters:
         Name  Flags
      trailer  

  void handleException(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // java.lang.Throwable cause
         0: .line 562
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 2
         1: .line 563
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.exceptionHandler:Lio/vertx/core/Handler;
            aload 1 /* cause */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         2: .line 565
      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    3     0   this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    3     1  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  void handleClosed();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 569
            aload 0 /* this */
            getstatic io.vertx.core.http.impl.Http1xClientConnection.CLOSED_EXCEPTION:Lio/vertx/core/VertxException;
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.handleException:(Ljava/lang/Throwable;)V
         1: .line 570
            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;

  private void lambda$0(io.vertx.core.http.impl.Http1xClientConnection, java.lang.Void);
    descriptor: (Lio/vertx/core/http/impl/Http1xClientConnection;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 2 // java.lang.Void v
         0: .line 337
            aload 1
            invokestatic io.vertx.core.http.impl.Http1xClientConnection.access$15:(Lio/vertx/core/http/impl/Http1xClientConnection;)Lio/vertx/core/impl/ContextInternal;
            invokeinterface io.vertx.core.impl.ContextInternal.nettyEventLoop:()Lio/netty/channel/EventLoop;
            astore 3 /* eventLoop */
        start local 3 // io.netty.channel.EventLoop eventLoop
         1: .line 338
            aload 3 /* eventLoop */
            invokeinterface io.netty.channel.EventLoop.inEventLoop:()Z
            ifeq 4
         2: .line 339
            aload 0 /* this */
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.drained:()V
         3: .line 340
            goto 5
         4: .line 341
      StackMap locals: io.netty.channel.EventLoop
      StackMap stack:
            aload 3 /* eventLoop */
            aload 0 /* this */
            invokedynamic run(Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;)Ljava/lang/Runnable;
              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:
                  ()V
                  io/vertx/core/http/impl/Http1xClientConnection$StreamImpl.drained()V (7)
                  ()V
            invokeinterface io.netty.channel.EventLoop.execute:(Ljava/lang/Runnable;)V
        end local 3 // io.netty.channel.EventLoop eventLoop
         5: .line 343
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Void v
        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     2          v  Ljava/lang/Void;
            1    5     3  eventLoop  Lio/netty/channel/EventLoop;

  private void lambda$2(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
        start local 1 // java.lang.Object item
         0: .line 345
            aload 1 /* item */
            instanceof io.vertx.core.MultiMap
            ifeq 5
         1: .line 346
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.endHandler:Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         2: .line 347
            aload 2 /* handler */
            ifnull 8
         3: .line 348
            aload 2 /* handler */
            aload 1 /* item */
            checkcast io.vertx.core.MultiMap
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 2 // io.vertx.core.Handler handler
         4: .line 350
            goto 8
         5: .line 351
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.chunkHandler:Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         6: .line 352
            aload 2 /* handler */
            ifnull 8
         7: .line 353
            aload 2 /* handler */
            aload 1 /* item */
            checkcast io.vertx.core.buffer.Buffer
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 2 // io.vertx.core.Handler handler
         8: .line 356
      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    9     0     this  Lio/vertx/core/http/impl/Http1xClientConnection$StreamImpl;
            0    9     1     item  Ljava/lang/Object;
            2    4     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/MultiMap;>;
            6    8     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;

  private void lambda$4(io.vertx.core.http.impl.HttpRequestHead, boolean, io.netty.buffer.ByteBuf, boolean, boolean, io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=7, locals=7, args_size=7
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 435
            aload 0 /* this */
            aload 1
            iload 2
            aload 3
            iload 4
            iload 5
            aload 6
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writeHead:(Lio/vertx/core/http/impl/HttpRequestHead;ZLio/netty/buffer/ByteBuf;ZZLio/vertx/core/Handler;)V
            return
        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;

  private void lambda$5(io.netty.buffer.ByteBuf, boolean, io.netty.util.concurrent.FutureListener);
    descriptor: (Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // io.vertx.core.http.impl.Http1xClientConnection$StreamImpl this
         0: .line 452
            aload 0 /* this */
            aload 1
            iload 2
            aload 3
            invokevirtual io.vertx.core.http.impl.Http1xClientConnection$StreamImpl.writeBuffer:(Lio/netty/buffer/ByteBuf;ZLio/netty/util/concurrent/FutureListener;)V
            return
        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;
}
SourceFile: "Http1xClientConnection.java"
NestHost: io.vertx.core.http.impl.Http1xClientConnection
InnerClasses:
  private abstract Stream = io.vertx.core.http.impl.Http1xClientConnection$Stream of io.vertx.core.http.impl.Http1xClientConnection
  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
/

io.vertx/ vertx-core/ 4.0.0/ io/vertx/core/http/impl/Http1xClientConnection$StreamImpl.class
