abstract class io.vertx.rx.java.ObservableReadStream$Adapter implements io.vertx.core.Handler<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
  this_class: io.vertx.rx.java.ObservableReadStream$Adapter
  super_class: java.lang.Object
{
  protected final rx.Subscriber<? super R> subscriber;
    descriptor: Lrx/Subscriber;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: Lrx/Subscriber<-TR;>;

  long requested;
    descriptor: J
    flags: (0x0000) 

  final io.vertx.rx.java.ObservableReadStream this$0;
    descriptor: Lio/vertx/rx/java/ObservableReadStream;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  void <init>(rx.Subscriber<? super R>);
    descriptor: (Lio/vertx/rx/java/ObservableReadStream;Lrx/Subscriber;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.rx.java.ObservableReadStream$Adapter this
        start local 2 // rx.Subscriber subscriber
         0: .line 124
            aload 0 /* this */
            aload 1
            putfield io.vertx.rx.java.ObservableReadStream$Adapter.this$0:Lio/vertx/rx/java/ObservableReadStream;
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 125
            aload 0 /* this */
            aload 2 /* subscriber */
            putfield io.vertx.rx.java.ObservableReadStream$Adapter.subscriber:Lrx/Subscriber;
         2: .line 126
            return
        end local 2 // rx.Subscriber subscriber
        end local 0 // io.vertx.rx.java.ObservableReadStream$Adapter this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lio/vertx/rx/java/ObservableReadStream$Adapter;
            0    3     2  subscriber  Lrx/Subscriber<-TR;>;
    Signature: (Lrx/Subscriber<-TR;>;)V
    MethodParameters:
            Name  Flags
      this$0      final
      subscriber  

  synchronized long requested();
    descriptor: ()J
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.rx.java.ObservableReadStream$Adapter this
         0: .line 129
            aload 0 /* this */
            getfield io.vertx.rx.java.ObservableReadStream$Adapter.this$0:Lio/vertx/rx/java/ObservableReadStream;
            dup
            astore 1
            monitorenter
         1: .line 130
            aload 0 /* this */
            getfield io.vertx.rx.java.ObservableReadStream$Adapter.requested:J
            aload 1
            monitorexit
         2: lreturn
         3: .line 129
      StackMap locals: io.vertx.rx.java.ObservableReadStream$Adapter io.vertx.rx.java.ObservableReadStream
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         4: athrow
        end local 0 // io.vertx.rx.java.ObservableReadStream$Adapter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/rx/java/ObservableReadStream$Adapter;
      Exception table:
        from    to  target  type
           1     2       3  any
           3     4       3  any

  void request(long);
    descriptor: (J)V
    flags: (0x0000) 
    Code:
      stack=6, locals=4, args_size=2
        start local 0 // io.vertx.rx.java.ObservableReadStream$Adapter this
        start local 1 // long n
         0: .line 140
            aload 0 /* this */
            getfield io.vertx.rx.java.ObservableReadStream$Adapter.this$0:Lio/vertx/rx/java/ObservableReadStream;
            dup
            astore 3
            monitorenter
         1: .line 141
            lload 1 /* n */
            ldc 9223372036854775807
            lcmp
            ifeq 2
            lload 1 /* n */
            ldc 9223372036854775807
            aload 0 /* this */
            getfield io.vertx.rx.java.ObservableReadStream$Adapter.requested:J
            lsub
            lcmp
            iflt 4
         2: .line 142
      StackMap locals: io.vertx.rx.java.ObservableReadStream
      StackMap stack:
            aload 0 /* this */
            ldc 9223372036854775807
            putfield io.vertx.rx.java.ObservableReadStream$Adapter.requested:J
         3: .line 143
            goto 5
         4: .line 144
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield io.vertx.rx.java.ObservableReadStream$Adapter.requested:J
            lload 1 /* n */
            ladd
            putfield io.vertx.rx.java.ObservableReadStream$Adapter.requested:J
         5: .line 140
      StackMap locals:
      StackMap stack:
            aload 3
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 3
            monitorexit
         8: athrow
         9: .line 147
      StackMap locals:
      StackMap stack:
            return
        end local 1 // long n
        end local 0 // io.vertx.rx.java.ObservableReadStream$Adapter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lio/vertx/rx/java/ObservableReadStream$Adapter;
            0   10     1     n  J
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any
    MethodParameters:
      Name  Flags
      n     

  abstract boolean dispose();
    descriptor: ()Z
    flags: (0x0400) ACC_ABSTRACT

  abstract void end(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0400) ACC_ABSTRACT
    MethodParameters:
      Name  Flags
      t     
}
Signature: Ljava/lang/Object;Lio/vertx/core/Handler<TT;>;
SourceFile: "ObservableReadStream.java"
NestHost: io.vertx.rx.java.ObservableReadStream
InnerClasses:
  private abstract Adapter = io.vertx.rx.java.ObservableReadStream$Adapter of io.vertx.rx.java.ObservableReadStream