java/12 : java.net.http/jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.class

ResponseSubscribers$PublishingBodySubscriber
https://openjdk.java.net/
GPLv2 + Classpath Exception
class jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber implements java.net.http.HttpResponse$BodySubscriber<java.util.concurrent.Flow$Publisher<java.util.List<java.nio.ByteBuffer>>>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber
  super_class: java.lang.Object
{
  private final jdk.internal.net.http.common.MinimalFuture<java.util.concurrent.Flow$Subscription> subscriptionCF;
    descriptor: Ljdk/internal/net/http/common/MinimalFuture;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljdk/internal/net/http/common/MinimalFuture<Ljava/util/concurrent/Flow$Subscription;>;

  private final jdk.internal.net.http.common.MinimalFuture<jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef> subscribedCF;
    descriptor: Ljdk/internal/net/http/common/MinimalFuture;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljdk/internal/net/http/common/MinimalFuture<Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;>;

  private java.util.concurrent.atomic.AtomicReference<jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef> subscriberRef;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;>;

  private final java.util.concurrent.CompletionStage<java.util.concurrent.Flow$Publisher<java.util.List<java.nio.ByteBuffer>>> body;
    descriptor: Ljava/util/concurrent/CompletionStage;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/CompletionStage<Ljava/util/concurrent/Flow$Publisher<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;>;

  private final jdk.internal.net.http.common.MinimalFuture<java.lang.Void> completionCF;
    descriptor: Ljdk/internal/net/http/common/MinimalFuture;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljdk/internal/net/http/common/MinimalFuture<Ljava/lang/Void;>;

  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 687
            ldc Ljdk/internal/net/http/ResponseSubscribers;
            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.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
         0: .line 702
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 690
            aload 0 /* this */
            new jdk.internal.net.http.common.MinimalFuture
            dup
            invokespecial jdk.internal.net.http.common.MinimalFuture.<init>:()V
            putfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
         2: .line 692
            aload 0 /* this */
            new jdk.internal.net.http.common.MinimalFuture
            dup
            invokespecial jdk.internal.net.http.common.MinimalFuture.<init>:()V
            putfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscribedCF:Ljdk/internal/net/http/common/MinimalFuture;
         3: .line 694
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
            putfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriberRef:Ljava/util/concurrent/atomic/AtomicReference;
         4: .line 695
            aload 0 /* this */
         5: .line 696
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
         6: .line 697
            aload 0 /* this */
            invokedynamic apply(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;)Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.lambda$0(Ljava/util/concurrent/Flow$Subscription;)Ljava/util/concurrent/CompletionStage; (7)
                  (Ljava/util/concurrent/Flow$Subscription;)Ljava/util/concurrent/CompletionStage;
         7: .line 696
            invokevirtual jdk.internal.net.http.common.MinimalFuture.thenCompose:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture;
            putfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.body:Ljava/util/concurrent/CompletionStage;
         8: .line 703
            aload 0 /* this */
            new jdk.internal.net.http.common.MinimalFuture
            dup
            invokespecial jdk.internal.net.http.common.MinimalFuture.<init>:()V
            putfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.completionCF:Ljdk/internal/net/http/common/MinimalFuture;
         9: .line 704
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.completionCF:Ljdk/internal/net/http/common/MinimalFuture;
        10: .line 705
            aload 0 /* this */
            invokedynamic accept(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.lambda$2(Ljava/lang/Void;Ljava/lang/Throwable;)V (7)
                  (Ljava/lang/Void;Ljava/lang/Throwable;)V
        11: .line 704
            invokevirtual jdk.internal.net.http.common.MinimalFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
            pop
        12: .line 706
            return
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   13     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;

  private void complete(jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef, java.lang.Throwable);
    descriptor: (Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;Ljava/lang/Throwable;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=3
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef ref
        start local 2 // java.lang.Throwable t
         0: .line 768
            getstatic jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.$assertionsDisabled:Z
            ifne 1
            aload 1 /* ref */
            ifnonnull 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 769
      StackMap locals:
      StackMap stack:
            aload 1 /* ref */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef.clear:()Ljava/util/concurrent/Flow$Subscriber;
            astore 3 /* s */
        start local 3 // java.util.concurrent.Flow$Subscriber s
         2: .line 771
            aload 3 /* s */
            ifnonnull 3
            return
         3: .line 772
      StackMap locals: java.util.concurrent.Flow$Subscriber
      StackMap stack:
            aload 2 /* t */
            ifnonnull 9
         4: .line 774
            aload 3 /* s */
            invokeinterface java.util.concurrent.Flow$Subscriber.onComplete:()V
         5: .line 775
            goto 10
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: astore 4 /* x */
        start local 4 // java.lang.Throwable x
         7: .line 776
            aload 3 /* s */
            aload 4 /* x */
            invokeinterface java.util.concurrent.Flow$Subscriber.onError:(Ljava/lang/Throwable;)V
        end local 4 // java.lang.Throwable x
         8: .line 778
            goto 10
         9: .line 779
      StackMap locals:
      StackMap stack:
            aload 3 /* s */
            aload 2 /* t */
            invokeinterface java.util.concurrent.Flow$Subscriber.onError:(Ljava/lang/Throwable;)V
        10: .line 781
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.util.concurrent.Flow$Subscriber s
        end local 2 // java.lang.Throwable t
        end local 1 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef ref
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   11     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0   11     1   ref  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;
            0   11     2     t  Ljava/lang/Throwable;
            2   11     3     s  Ljava/util/concurrent/Flow$Subscriber<*>;
            7    8     4     x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           4     5       6  Class java.lang.Throwable
    MethodParameters:
      Name  Flags
      ref   
      t     

  private void signalError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.lang.Throwable err
         0: .line 784
            aload 1 /* err */
            ifnonnull 2
         1: .line 785
            new java.lang.NullPointerException
            dup
            ldc "null throwable"
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            astore 1 /* err */
         2: .line 787
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.completionCF:Ljdk/internal/net/http/common/MinimalFuture;
            aload 1 /* err */
            invokevirtual jdk.internal.net.http.common.MinimalFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
         3: .line 788
            return
        end local 1 // java.lang.Throwable err
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    4     1   err  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      err   

  private void signalComplete();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
         0: .line 791
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.completionCF:Ljdk/internal/net/http/common/MinimalFuture;
            aconst_null
            invokevirtual jdk.internal.net.http.common.MinimalFuture.complete:(Ljava/lang/Object;)Z
            pop
         1: .line 792
            return
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;

  private void subscribe(java.util.concurrent.Flow$Subscriber<? super java.util.List<java.nio.ByteBuffer>>);
    descriptor: (Ljava/util/concurrent/Flow$Subscriber;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.util.concurrent.Flow$Subscriber subscriber
         0: .line 795
            aload 1 /* subscriber */
            ldc "subscriber must not be null"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 796
            new jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef
            dup
            aload 1 /* subscriber */
            invokespecial jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef.<init>:(Ljava/util/concurrent/Flow$Subscriber;)V
            astore 2 /* ref */
        start local 2 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef ref
         2: .line 797
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriberRef:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            aload 2 /* ref */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 5
         3: .line 798
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
            aload 0 /* this */
            aload 2 /* ref */
            invokedynamic accept(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.lambda$4(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;Ljava/util/concurrent/Flow$Subscription;)V (7)
                  (Ljava/util/concurrent/Flow$Subscription;)V
            invokevirtual jdk.internal.net.http.common.MinimalFuture.thenAccept:(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;
            pop
         4: .line 812
            goto 9
         5: .line 813
      StackMap locals: jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef
      StackMap stack:
            aload 1 /* subscriber */
            new jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$1
            dup
            aload 0 /* this */
            invokespecial jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$1.<init>:(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;)V
            invokeinterface java.util.concurrent.Flow$Subscriber.onSubscribe:(Ljava/util/concurrent/Flow$Subscription;)V
         6: .line 817
            aload 1 /* subscriber */
            new java.lang.IllegalStateException
            dup
         7: .line 818
            ldc "This publisher has already one subscriber"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
         8: .line 817
            invokeinterface java.util.concurrent.Flow$Subscriber.onError:(Ljava/lang/Throwable;)V
         9: .line 820
      StackMap locals:
      StackMap stack:
            return
        end local 2 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef ref
        end local 1 // java.util.concurrent.Flow$Subscriber subscriber
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0        this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0   10     1  subscriber  Ljava/util/concurrent/Flow$Subscriber<-Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
            2   10     2         ref  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;
    Signature: (Ljava/util/concurrent/Flow$Subscriber<-Ljava/util/List<Ljava/nio/ByteBuffer;>;>;)V
    MethodParameters:
            Name  Flags
      subscriber  

  public void onSubscribe(java.util.concurrent.Flow$Subscription);
    descriptor: (Ljava/util/concurrent/Flow$Subscription;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.util.concurrent.Flow$Subscription subscription
         0: .line 824
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
            aload 1 /* subscription */
            invokevirtual jdk.internal.net.http.common.MinimalFuture.complete:(Ljava/lang/Object;)Z
            pop
         1: .line 825
            return
        end local 1 // java.util.concurrent.Flow$Subscription subscription
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    2     0          this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    2     1  subscription  Ljava/util/concurrent/Flow$Subscription;
    MethodParameters:
              Name  Flags
      subscription  

  public void onNext(java.util.List<java.nio.ByteBuffer>);
    descriptor: (Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.util.List item
         0: .line 831
            getstatic jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
            invokevirtual jdk.internal.net.http.common.MinimalFuture.isDone:()Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 832
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriberRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef
            astore 2 /* ref */
        start local 2 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef ref
         2: .line 834
            getstatic jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.$assertionsDisabled:Z
            ifne 3
            aload 2 /* ref */
            ifnonnull 3
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         3: .line 836
      StackMap locals: jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef
      StackMap stack:
            aload 2 /* ref */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef.get:()Ljava/util/concurrent/Flow$Subscriber;
            astore 3 /* subscriber */
        start local 3 // java.util.concurrent.Flow$Subscriber subscriber
         4: .line 837
            aload 3 /* subscriber */
            ifnull 10
         5: .line 839
            aload 3 /* subscriber */
            aload 1 /* item */
            invokeinterface java.util.concurrent.Flow$Subscriber.onNext:(Ljava/lang/Object;)V
        end local 3 // java.util.concurrent.Flow$Subscriber subscriber
        end local 2 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef ref
         6: .line 841
            goto 10
      StackMap locals: jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber java.util.List
      StackMap stack: java.lang.Throwable
         7: astore 2 /* err */
        start local 2 // java.lang.Throwable err
         8: .line 842
            aload 0 /* this */
            aload 2 /* err */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.signalError:(Ljava/lang/Throwable;)V
         9: .line 843
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
            invokedynamic accept()Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.lambda$5(Ljava/util/concurrent/Flow$Subscription;)V (6)
                  (Ljava/util/concurrent/Flow$Subscription;)V
            invokevirtual jdk.internal.net.http.common.MinimalFuture.thenAccept:(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;
            pop
        end local 2 // java.lang.Throwable err
        10: .line 845
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.util.List item
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   11     0        this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0   11     1        item  Ljava/util/List<Ljava/nio/ByteBuffer;>;
            2    6     2         ref  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;
            4    6     3  subscriber  Ljava/util/concurrent/Flow$Subscriber<-Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
            8   10     2         err  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     6       7  Class java.lang.Throwable
    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=4, locals=2, args_size=2
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.lang.Throwable throwable
         0: .line 850
            getstatic jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.$assertionsDisabled:Z
            ifne 5
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
            invokevirtual jdk.internal.net.http.common.MinimalFuture.isDone:()Z
         1: .line 851
            ldc "onError called before onSubscribe"
         2: .line 852
            aload 1 /* throwable */
         3: .line 850
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.suppress:(ZLjava/lang/String;Ljava/lang/Throwable;)Z
         4: .line 852
            ifne 5
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         5: .line 855
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* throwable */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.signalError:(Ljava/lang/Throwable;)V
         6: .line 856
            return
        end local 1 // java.lang.Throwable throwable
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    7     1  throwable  Ljava/lang/Throwable;
    MethodParameters:
           Name  Flags
      throwable  

  public void onComplete();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
         0: .line 861
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscriptionCF:Ljdk/internal/net/http/common/MinimalFuture;
            invokevirtual jdk.internal.net.http.common.MinimalFuture.isDone:()Z
            ifne 5
         1: .line 862
            aload 0 /* this */
            new java.lang.InternalError
            dup
         2: .line 863
            ldc "onComplete called before onSubscribed"
            invokespecial java.lang.InternalError.<init>:(Ljava/lang/String;)V
         3: .line 862
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.signalError:(Ljava/lang/Throwable;)V
         4: .line 864
            goto 6
         5: .line 868
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.signalComplete:()V
         6: .line 870
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;

  public java.util.concurrent.CompletionStage<java.util.concurrent.Flow$Publisher<java.util.List<java.nio.ByteBuffer>>> getBody();
    descriptor: ()Ljava/util/concurrent/CompletionStage;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
         0: .line 874
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.body:Ljava/util/concurrent/CompletionStage;
            areturn
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
    Signature: ()Ljava/util/concurrent/CompletionStage<Ljava/util/concurrent/Flow$Publisher<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;>;

  private boolean suppress(boolean, java.lang.String, java.lang.Throwable);
    descriptor: (ZLjava/lang/String;Ljava/lang/Throwable;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // boolean condition
        start local 2 // java.lang.String assertion
        start local 3 // java.lang.Throwable carrier
         0: .line 880
            iload 1 /* condition */
            ifne 6
         1: .line 881
            aload 3 /* carrier */
            ifnull 4
         2: .line 882
            aload 3 /* carrier */
            new java.lang.AssertionError
            dup
            aload 2 /* assertion */
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
         3: .line 883
            goto 6
      StackMap locals:
      StackMap stack:
         4: invokestatic jdk.internal.net.http.common.Log.errors:()Z
            ifeq 6
         5: .line 884
            new java.lang.AssertionError
            dup
            aload 2 /* assertion */
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            invokestatic jdk.internal.net.http.common.Log.logError:(Ljava/lang/Throwable;)V
         6: .line 887
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 3 // java.lang.Throwable carrier
        end local 2 // java.lang.String assertion
        end local 1 // boolean condition
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    7     1  condition  Z
            0    7     2  assertion  Ljava/lang/String;
            0    7     3    carrier  Ljava/lang/Throwable;
    MethodParameters:
           Name  Flags
      condition  
      assertion  
      carrier    

  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.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.onNext:(Ljava/util/List;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private java.util.concurrent.CompletionStage lambda$0(java.util.concurrent.Flow$Subscription);
    descriptor: (Ljava/util/concurrent/Flow$Subscription;)Ljava/util/concurrent/CompletionStage;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.util.concurrent.Flow$Subscription s
         0: .line 697
            aload 0 /* this */
            invokedynamic subscribe(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;)Ljava/util/concurrent/Flow$Publisher;
              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/util/concurrent/Flow$Subscriber;)V
                  jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.subscribe(Ljava/util/concurrent/Flow$Subscriber;)V (7)
                  (Ljava/util/concurrent/Flow$Subscriber;)V
            invokestatic jdk.internal.net.http.common.MinimalFuture.completedFuture:(Ljava/lang/Object;)Ljdk/internal/net/http/common/MinimalFuture;
            areturn
        end local 1 // java.util.concurrent.Flow$Subscription s
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    1     1     s  Ljava/util/concurrent/Flow$Subscription;

  private void lambda$2(java.lang.Void, java.lang.Throwable);
    descriptor: (Ljava/lang/Void;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 1 // java.lang.Void r
        start local 2 // java.lang.Throwable t
         0: .line 705
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscribedCF:Ljdk/internal/net/http/common/MinimalFuture;
            aload 0 /* this */
            aload 2 /* t */
            invokedynamic accept(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;Ljava/lang/Throwable;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.lambda$3(Ljava/lang/Throwable;Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;)V (7)
                  (Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;)V
            invokevirtual jdk.internal.net.http.common.MinimalFuture.thenAccept:(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;
            return
        end local 2 // java.lang.Throwable t
        end local 1 // java.lang.Void r
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    1     1     r  Ljava/lang/Void;
            0    1     2     t  Ljava/lang/Throwable;

  private void lambda$4(jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef, java.util.concurrent.Flow$Subscription);
    descriptor: (Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;Ljava/util/concurrent/Flow$Subscription;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 2 // java.util.concurrent.Flow$Subscription s
         0: .line 799
            new jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef
            dup
            aload 2 /* s */
            aload 1
            invokespecial jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef.<init>:(Ljava/util/concurrent/Flow$Subscription;Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;)V
            astore 3 /* subscription */
        start local 3 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef subscription
         1: .line 801
            aload 3 /* subscription */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef.subscribe:()V
         2: .line 802
            aload 0 /* this */
            getfield jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.subscribedCF:Ljdk/internal/net/http/common/MinimalFuture;
            aload 1
            invokevirtual jdk.internal.net.http.common.MinimalFuture.complete:(Ljava/lang/Object;)Z
            pop
         3: .line 803
            goto 11
      StackMap locals: jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef java.util.concurrent.Flow$Subscription jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef
      StackMap stack: java.lang.Throwable
         4: astore 4 /* t */
        start local 4 // java.lang.Throwable t
         5: .line 804
            invokestatic jdk.internal.net.http.common.Log.errors:()Z
            ifeq 10
         6: .line 805
            new java.lang.StringBuilder
            dup
            ldc "Failed to call onSubscribe: cancelling subscription: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
         7: .line 806
            aload 4 /* t */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         8: .line 805
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            iconst_0
            anewarray java.lang.Object
            invokestatic jdk.internal.net.http.common.Log.logError:(Ljava/lang/String;[Ljava/lang/Object;)V
         9: .line 807
            aload 4 /* t */
            invokestatic jdk.internal.net.http.common.Log.logError:(Ljava/lang/Throwable;)V
        10: .line 809
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 3 /* subscription */
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef.cancel:()V
        end local 4 // java.lang.Throwable t
        end local 3 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef subscription
        11: .line 811
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.util.concurrent.Flow$Subscription s
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   12     0          this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0   12     2             s  Ljava/util/concurrent/Flow$Subscription;
            1   11     3  subscription  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef;
            5   11     4             t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     3       4  Class java.lang.Throwable

  private static void lambda$5(java.util.concurrent.Flow$Subscription);
    descriptor: (Ljava/util/concurrent/Flow$Subscription;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.util.concurrent.Flow$Subscription s
         0: .line 843
            aload 0 /* s */
            invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
            return
        end local 0 // java.util.concurrent.Flow$Subscription s
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     s  Ljava/util/concurrent/Flow$Subscription;

  private void lambda$3(java.lang.Throwable, jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef);
    descriptor: (Ljava/lang/Throwable;Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
        start local 2 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef s
         0: .line 705
            aload 0 /* this */
            aload 2 /* s */
            aload 1
            invokevirtual jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber.complete:(Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;Ljava/lang/Throwable;)V
            return
        end local 2 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef s
        end local 0 // jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber;
            0    1     2     s  Ljdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber$SubscriberRef;
}
Signature: Ljava/lang/Object;Ljava/net/http/HttpResponse$BodySubscriber<Ljava/util/concurrent/Flow$Publisher<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;>;
SourceFile: "ResponseSubscribers.java"
NestHost: jdk.internal.net.http.ResponseSubscribers
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract BodySubscriber = java.net.http.HttpResponse$BodySubscriber of java.net.http.HttpResponse
  public abstract Publisher = java.util.concurrent.Flow$Publisher of java.util.concurrent.Flow
  public abstract Subscriber = java.util.concurrent.Flow$Subscriber of java.util.concurrent.Flow
  public abstract Subscription = java.util.concurrent.Flow$Subscription of java.util.concurrent.Flow
  PublishingBodySubscriber = jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber of jdk.internal.net.http.ResponseSubscribers
  jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$1
  final SubscriberRef = jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriberRef of jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber
  final SubscriptionRef = jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber$SubscriptionRef of jdk.internal.net.http.ResponseSubscribers$PublishingBodySubscriber
/

java/ 12/ java.net.http/jdk/internal/net/http/ResponseSubscribers$PublishingBodySubscriber.class
