class jdk.incubator.http.BufferingSubscriber<T> implements jdk.incubator.http.HttpResponse$BodySubscriber<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: jdk.incubator.http.BufferingSubscriber
  super_class: java.lang.Object
{
  private final jdk.incubator.http.HttpResponse$BodySubscriber<T> downstreamSubscriber;
    descriptor: Ljdk/incubator/http/HttpResponse$BodySubscriber;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljdk/incubator/http/HttpResponse$BodySubscriber<TT;>;

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

  private volatile java.util.concurrent.Flow$Subscription subscription;
    descriptor: Ljava/util/concurrent/Flow$Subscription;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile jdk.incubator.http.BufferingSubscriber<T>.DownstreamSubscription downstreamSubscription;
    descriptor: Ljdk/incubator/http/BufferingSubscriber$DownstreamSubscription;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
    Signature: Ljdk/incubator/http/BufferingSubscriber<TT;>.DownstreamSubscription;

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

  private java.util.ArrayList<java.nio.ByteBuffer> internalBuffers;
    descriptor: Ljava/util/ArrayList;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/ArrayList<Ljava/nio/ByteBuffer;>;

  private int accumulatedBytes;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private volatile java.lang.Throwable throwable;
    descriptor: Ljava/lang/Throwable;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  static final int UNSUBSCRIBED;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: 1

  static final int ACTIVE;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: 2

  static final int ERROR;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: 4

  static final int CANCELLED;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: 8

  static final int COMPLETE;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: 16

  private volatile int state;
    descriptor: I
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 46
            ldc Ljdk/incubator/http/BufferingSubscriber;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
         3: .line 77
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(jdk.incubator.http.HttpResponse$BodySubscriber<T>, );
    descriptor: (Ljdk/incubator/http/HttpResponse$BodySubscriber;I)V
    flags: (0x0000) 
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // jdk.incubator.http.BufferingSubscriber this
        start local 1 // jdk.incubator.http.HttpResponse$BodySubscriber downstreamSubscriber
        start local 2 // int bufferSize
         0: .line 81
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 59
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield jdk.incubator.http.BufferingSubscriber.buffersLock:Ljava/lang/Object;
         2: .line 83
            aload 0 /* this */
            aload 1 /* downstreamSubscriber */
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast jdk.incubator.http.HttpResponse$BodySubscriber
            putfield jdk.incubator.http.BufferingSubscriber.downstreamSubscriber:Ljdk/incubator/http/HttpResponse$BodySubscriber;
         3: .line 84
            aload 0 /* this */
            iload 2 /* bufferSize */
            putfield jdk.incubator.http.BufferingSubscriber.bufferSize:I
         4: .line 85
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.buffersLock:Ljava/lang/Object;
            dup
            astore 3
            monitorenter
         5: .line 86
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            putfield jdk.incubator.http.BufferingSubscriber.internalBuffers:Ljava/util/ArrayList;
         6: .line 85
            aload 3
            monitorexit
         7: goto 10
      StackMap locals: jdk.incubator.http.BufferingSubscriber jdk.incubator.http.HttpResponse$BodySubscriber int java.lang.Object
      StackMap stack: java.lang.Throwable
         8: aload 3
            monitorexit
         9: athrow
        10: .line 88
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield jdk.incubator.http.BufferingSubscriber.state:I
        11: .line 89
            return
        end local 2 // int bufferSize
        end local 1 // jdk.incubator.http.HttpResponse$BodySubscriber downstreamSubscriber
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   12     0                  this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
            0   12     1  downstreamSubscriber  Ljdk/incubator/http/HttpResponse$BodySubscriber<TT;>;
            0   12     2            bufferSize  I
      Exception table:
        from    to  target  type
           5     7       8  any
           8     9       8  any
    Signature: (Ljdk/incubator/http/HttpResponse$BodySubscriber<TT;>;I)V
    MethodParameters:
                      Name  Flags
      downstreamSubscriber  
      bufferSize            

  private static final long remaining(java.util.List<java.nio.ByteBuffer>);
    descriptor: (Ljava/util/List;)J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.List buffers
         0: .line 93
            aload 0 /* buffers */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            invokedynamic applyAsLong()Ljava/util/function/ToLongFunction;
              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;)J
                  java/nio/Buffer.remaining()I (5)
                  (Ljava/nio/ByteBuffer;)J
            invokeinterface java.util.stream.Stream.mapToLong:(Ljava/util/function/ToLongFunction;)Ljava/util/stream/LongStream;
            invokeinterface java.util.stream.LongStream.sum:()J
            lreturn
        end local 0 // java.util.List buffers
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  buffers  Ljava/util/List<Ljava/nio/ByteBuffer;>;
    Signature: (Ljava/util/List<Ljava/nio/ByteBuffer;>;)J
    MethodParameters:
         Name  Flags
      buffers  

  private final boolean hasEnoughAccumulatedBytes();
    descriptor: ()Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.incubator.http.BufferingSubscriber this
         0: .line 102
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.buffersLock:Ljava/lang/Object;
            invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 103
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.bufferSize:I
            if_icmpge 5
         2: .line 104
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.state:I
            bipush 16
            if_icmpne 4
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
         3: .line 103
            ifgt 5
      StackMap locals:
      StackMap stack:
         4: iconst_0
            ireturn
      StackMap locals:
      StackMap stack:
         5: iconst_1
            ireturn
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Ljdk/incubator/http/BufferingSubscriber<TT;>;

  private java.util.List<java.nio.ByteBuffer> fromInternalBuffers();
    descriptor: ()Ljava/util/List;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=8, args_size=1
        start local 0 // jdk.incubator.http.BufferingSubscriber this
         0: .line 114
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.buffersLock:Ljava/lang/Object;
            invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 115
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.bufferSize:I
            istore 1 /* leftToFill */
        start local 1 // int leftToFill
         2: .line 116
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.state:I
            istore 2 /* state */
        start local 2 // int state
         3: .line 117
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 5
            iload 2 /* state */
            iconst_2
            if_icmpeq 4
            iload 2 /* state */
            bipush 8
            if_icmpne 5
         4: .line 118
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
            iload 1 /* leftToFill */
            if_icmpge 5
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         5: .line 119
      StackMap locals:
      StackMap stack:
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 3 /* dsts */
        start local 3 // java.util.List dsts
         6: .line 121
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.internalBuffers:Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.listIterator:()Ljava/util/ListIterator;
            astore 4 /* itr */
        start local 4 // java.util.ListIterator itr
         7: .line 122
            goto 27
         8: .line 123
      StackMap locals: java.util.List java.util.ListIterator
      StackMap stack:
            aload 4 /* itr */
            invokeinterface java.util.ListIterator.next:()Ljava/lang/Object;
            checkcast java.nio.ByteBuffer
            astore 5 /* b */
        start local 5 // java.nio.ByteBuffer b
         9: .line 124
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            iload 1 /* leftToFill */
            if_icmpgt 18
        10: .line 125
            aload 4 /* itr */
            invokeinterface java.util.ListIterator.remove:()V
        11: .line 126
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.position:()I
            ifeq 13
        12: .line 127
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.slice:()Ljava/nio/ByteBuffer;
            astore 5 /* b */
        13: .line 128
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            aload 3 /* dsts */
            aload 5 /* b */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        14: .line 129
            iload 1 /* leftToFill */
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            isub
            istore 1 /* leftToFill */
        15: .line 130
            aload 0 /* this */
            dup
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            isub
            putfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
        16: .line 131
            iload 1 /* leftToFill */
            ifne 27
        17: .line 132
            goto 28
        18: .line 134
      StackMap locals:
      StackMap stack:
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.limit:()I
            istore 6 /* prevLimit */
        start local 6 // int prevLimit
        19: .line 135
            aload 5 /* b */
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 1 /* leftToFill */
            iadd
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/ByteBuffer;
            pop
        20: .line 136
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.slice:()Ljava/nio/ByteBuffer;
            astore 7 /* slice */
        start local 7 // java.nio.ByteBuffer slice
        21: .line 137
            aload 3 /* dsts */
            aload 7 /* slice */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        22: .line 138
            aload 5 /* b */
            iload 6 /* prevLimit */
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/ByteBuffer;
            pop
        23: .line 139
            aload 5 /* b */
            aload 5 /* b */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 1 /* leftToFill */
            iadd
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/ByteBuffer;
            pop
        24: .line 140
            aload 0 /* this */
            dup
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
            iload 1 /* leftToFill */
            isub
            putfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
        25: .line 141
            iconst_0
            istore 1 /* leftToFill */
        26: .line 142
            goto 28
        end local 7 // java.nio.ByteBuffer slice
        end local 6 // int prevLimit
        end local 5 // java.nio.ByteBuffer b
        27: .line 122
      StackMap locals:
      StackMap stack:
            aload 4 /* itr */
            invokeinterface java.util.ListIterator.hasNext:()Z
            ifne 8
        28: .line 145
      StackMap locals:
      StackMap stack:
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 32
            iload 2 /* state */
            iconst_2
            if_icmpeq 29
            iload 2 /* state */
            bipush 8
            if_icmpne 30
        29: .line 146
      StackMap locals:
      StackMap stack:
            iload 1 /* leftToFill */
            ifeq 32
            goto 31
      StackMap locals:
      StackMap stack:
        30: iload 2 /* state */
            bipush 16
            if_icmpeq 32
      StackMap locals:
      StackMap stack:
        31: new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        32: .line 147
      StackMap locals:
      StackMap stack:
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 36
            iload 2 /* state */
            iconst_2
            if_icmpeq 33
            iload 2 /* state */
            bipush 8
            if_icmpne 34
        33: .line 148
      StackMap locals:
      StackMap stack:
            aload 3 /* dsts */
            invokestatic jdk.incubator.http.BufferingSubscriber.remaining:(Ljava/util/List;)J
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.bufferSize:I
            i2l
            lcmp
            ifeq 36
            goto 35
      StackMap locals:
      StackMap stack:
        34: iload 2 /* state */
            bipush 16
            if_icmpeq 36
      StackMap locals:
      StackMap stack:
        35: new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        36: .line 149
      StackMap locals:
      StackMap stack:
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 37
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
            ifge 37
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        37: .line 150
      StackMap locals:
      StackMap stack:
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 38
            aload 3 /* dsts */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            invokedynamic test()Ljava/util/function/Predicate;
              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;)Z
                  jdk/incubator/http/BufferingSubscriber.lambda$1(Ljava/nio/ByteBuffer;)Z (6)
                  (Ljava/nio/ByteBuffer;)Z
            invokeinterface java.util.stream.Stream.noneMatch:(Ljava/util/function/Predicate;)Z
            ifne 38
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        38: .line 151
      StackMap locals:
      StackMap stack:
            aload 3 /* dsts */
            invokestatic java.util.Collections.unmodifiableList:(Ljava/util/List;)Ljava/util/List;
            areturn
        end local 4 // java.util.ListIterator itr
        end local 3 // java.util.List dsts
        end local 2 // int state
        end local 1 // int leftToFill
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   39     0        this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
            2   39     1  leftToFill  I
            3   39     2       state  I
            6   39     3        dsts  Ljava/util/List<Ljava/nio/ByteBuffer;>;
            7   39     4         itr  Ljava/util/ListIterator<Ljava/nio/ByteBuffer;>;
            9   27     5           b  Ljava/nio/ByteBuffer;
           19   27     6   prevLimit  I
           21   27     7       slice  Ljava/nio/ByteBuffer;
    Signature: ()Ljava/util/List<Ljava/nio/ByteBuffer;>;

  public void onSubscribe(java.util.concurrent.Flow$Subscription);
    descriptor: (Ljava/util/concurrent/Flow$Subscription;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // jdk.incubator.http.BufferingSubscriber this
        start local 1 // java.util.concurrent.Flow$Subscription subscription
         0: .line 257
            aload 1 /* subscription */
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 258
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
            ifnull 4
         2: .line 259
            aload 1 /* subscription */
            invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
         3: .line 260
            return
         4: .line 263
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.state:I
            istore 2 /* s */
        start local 2 // int s
         5: .line 264
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 6
            iload 2 /* s */
            iconst_1
            if_icmpeq 6
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         6: .line 265
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            iconst_2
            putfield jdk.incubator.http.BufferingSubscriber.state:I
         7: .line 266
            aload 0 /* this */
            aload 1 /* subscription */
            putfield jdk.incubator.http.BufferingSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
         8: .line 267
            aload 0 /* this */
            new jdk.incubator.http.BufferingSubscriber$DownstreamSubscription
            dup
            aload 0 /* this */
            invokespecial jdk.incubator.http.BufferingSubscriber$DownstreamSubscription.<init>:(Ljdk/incubator/http/BufferingSubscriber;)V
            putfield jdk.incubator.http.BufferingSubscriber.downstreamSubscription:Ljdk/incubator/http/BufferingSubscriber$DownstreamSubscription;
         9: .line 268
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.downstreamSubscriber:Ljdk/incubator/http/HttpResponse$BodySubscriber;
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.downstreamSubscription:Ljdk/incubator/http/BufferingSubscriber$DownstreamSubscription;
            invokeinterface jdk.incubator.http.HttpResponse$BodySubscriber.onSubscribe:(Ljava/util/concurrent/Flow$Subscription;)V
        10: .line 269
            return
        end local 2 // int s
        end local 1 // java.util.concurrent.Flow$Subscription subscription
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   11     0          this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
            0   11     1  subscription  Ljava/util/concurrent/Flow$Subscription;
            5   11     2             s  I
    MethodParameters:
              Name  Flags
      subscription  

  public void onNext(java.util.List<java.nio.ByteBuffer>);
    descriptor: (Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // jdk.incubator.http.BufferingSubscriber this
        start local 1 // java.util.List item
         0: .line 273
            aload 1 /* item */
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 275
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.state:I
            istore 2 /* s */
        start local 2 // int s
         2: .line 276
            iload 2 /* s */
            bipush 8
            if_icmpne 4
         3: .line 277
            return
         4: .line 279
      StackMap locals: int
      StackMap stack:
            iload 2 /* s */
            iconst_2
            if_icmpeq 6
         5: .line 280
            new java.lang.InternalError
            dup
            ldc "onNext on inactive subscriber"
            invokespecial java.lang.InternalError.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 282
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.buffersLock:Ljava/lang/Object;
            dup
            astore 3
            monitorenter
         7: .line 283
            aload 0 /* this */
            dup
            getfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
            i2l
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.internalBuffers:Ljava/util/ArrayList;
            aload 1 /* item */
            invokestatic jdk.incubator.http.internal.common.Utils.accumulateBuffers:(Ljava/util/List;Ljava/util/List;)J
            ladd
            l2i
            putfield jdk.incubator.http.BufferingSubscriber.accumulatedBytes:I
         8: .line 282
            aload 3
            monitorexit
         9: goto 12
      StackMap locals: jdk.incubator.http.BufferingSubscriber java.util.List int java.lang.Object
      StackMap stack: java.lang.Throwable
        10: aload 3
            monitorexit
        11: athrow
        12: .line 286
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.downstreamSubscription:Ljdk/incubator/http/BufferingSubscriber$DownstreamSubscription;
            invokevirtual jdk.incubator.http.BufferingSubscriber$DownstreamSubscription.pushDemanded:()V
        13: .line 287
            return
        end local 2 // int s
        end local 1 // java.util.List item
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   14     0  this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
            0   14     1  item  Ljava/util/List<Ljava/nio/ByteBuffer;>;
            2   14     2     s  I
      Exception table:
        from    to  target  type
           7     9      10  any
          10    11      10  any
    Signature: (Ljava/util/List<Ljava/nio/ByteBuffer;>;)V
    MethodParameters:
      Name  Flags
      item  

  public void onError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // jdk.incubator.http.BufferingSubscriber this
        start local 1 // java.lang.Throwable incomingThrowable
         0: .line 291
            aload 1 /* incomingThrowable */
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 292
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.state:I
            istore 2 /* s */
        start local 2 // int s
         2: .line 293
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 3
            iload 2 /* s */
            iconst_2
            if_icmpeq 3
            new java.lang.AssertionError
            dup
            new java.lang.StringBuilder
            dup
            ldc "Expected ACTIVE, got:"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* s */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            athrow
         3: .line 294
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            iconst_4
            putfield jdk.incubator.http.BufferingSubscriber.state:I
         4: .line 295
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.throwable:Ljava/lang/Throwable;
            astore 3 /* t */
        start local 3 // java.lang.Throwable t
         5: .line 296
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 6
            aload 3 /* t */
            ifnull 6
            new java.lang.AssertionError
            dup
            new java.lang.StringBuilder
            dup
            ldc "Expected null, got:"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* t */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            athrow
         6: .line 297
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            aload 1 /* incomingThrowable */
            putfield jdk.incubator.http.BufferingSubscriber.throwable:Ljava/lang/Throwable;
         7: .line 298
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.downstreamSubscription:Ljdk/incubator/http/BufferingSubscriber$DownstreamSubscription;
            invokevirtual jdk.incubator.http.BufferingSubscriber$DownstreamSubscription.pushDemanded:()V
         8: .line 299
            return
        end local 3 // java.lang.Throwable t
        end local 2 // int s
        end local 1 // java.lang.Throwable incomingThrowable
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    9     0               this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
            0    9     1  incomingThrowable  Ljava/lang/Throwable;
            2    9     2                  s  I
            5    9     3                  t  Ljava/lang/Throwable;
    MethodParameters:
                   Name  Flags
      incomingThrowable  

  public void onComplete();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=1
        start local 0 // jdk.incubator.http.BufferingSubscriber this
         0: .line 303
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.state:I
            istore 1 /* s */
        start local 1 // int s
         1: .line 304
            getstatic jdk.incubator.http.BufferingSubscriber.$assertionsDisabled:Z
            ifne 2
            iload 1 /* s */
            iconst_2
            if_icmpeq 2
            new java.lang.AssertionError
            dup
            new java.lang.StringBuilder
            dup
            ldc "Expected ACTIVE, got:"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 1 /* s */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            athrow
         2: .line 305
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            bipush 16
            putfield jdk.incubator.http.BufferingSubscriber.state:I
         3: .line 306
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.downstreamSubscription:Ljdk/incubator/http/BufferingSubscriber$DownstreamSubscription;
            invokevirtual jdk.incubator.http.BufferingSubscriber$DownstreamSubscription.pushDemanded:()V
         4: .line 307
            return
        end local 1 // int s
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
            1    5     1     s  I

  public java.util.concurrent.CompletionStage<T> getBody();
    descriptor: ()Ljava/util/concurrent/CompletionStage;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.incubator.http.BufferingSubscriber this
         0: .line 311
            aload 0 /* this */
            getfield jdk.incubator.http.BufferingSubscriber.downstreamSubscriber:Ljdk/incubator/http/HttpResponse$BodySubscriber;
            invokeinterface jdk.incubator.http.HttpResponse$BodySubscriber.getBody:()Ljava/util/concurrent/CompletionStage;
            areturn
        end local 0 // jdk.incubator.http.BufferingSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/BufferingSubscriber<TT;>;
    Signature: ()Ljava/util/concurrent/CompletionStage<TT;>;

  public void onNext(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast java.util.List
            invokevirtual jdk.incubator.http.BufferingSubscriber.onNext:(Ljava/util/List;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static boolean lambda$1(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)Z
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.nio.ByteBuffer b
         0: .line 150
            aload 0 /* b */
            invokevirtual java.nio.ByteBuffer.position:()I
            ifeq 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: ireturn
        end local 0 // java.nio.ByteBuffer b
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0     b  Ljava/nio/ByteBuffer;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Ljdk/incubator/http/HttpResponse$BodySubscriber<TT;>;
SourceFile: "BufferingSubscriber.java"
NestMembers:
  jdk.incubator.http.BufferingSubscriber$DownstreamSubscription  jdk.incubator.http.BufferingSubscriber$DownstreamSubscription$PushDemandedTask
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract Subscription = java.util.concurrent.Flow$Subscription of java.util.concurrent.Flow
  private DownstreamSubscription = jdk.incubator.http.BufferingSubscriber$DownstreamSubscription of jdk.incubator.http.BufferingSubscriber
  public abstract BodySubscriber = jdk.incubator.http.HttpResponse$BodySubscriber of jdk.incubator.http.HttpResponse