final class java.util.concurrent.SubmissionPublisher$ConsumerSubscriber<T> implements java.util.concurrent.Flow$Subscriber<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: java.util.concurrent.SubmissionPublisher$ConsumerSubscriber
  super_class: java.lang.Object
{
  final java.util.concurrent.CompletableFuture<java.lang.Void> status;
    descriptor: Ljava/util/concurrent/CompletableFuture;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;

  final java.util.function.Consumer<? super T> consumer;
    descriptor: Ljava/util/function/Consumer;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/function/Consumer<-TT;>;

  java.util.concurrent.Flow$Subscription subscription;
    descriptor: Ljava/util/concurrent/Flow$Subscription;
    flags: (0x0000) 

  void <init>(java.util.concurrent.CompletableFuture<java.lang.Void>, java.util.function.Consumer<? super T>);
    descriptor: (Ljava/util/concurrent/CompletableFuture;Ljava/util/function/Consumer;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
        start local 1 // java.util.concurrent.CompletableFuture status
        start local 2 // java.util.function.Consumer consumer
         0: .line 887
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 889
            aload 0 /* this */
            aload 1 /* status */
            putfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.status:Ljava/util/concurrent/CompletableFuture;
            aload 0 /* this */
            aload 2 /* consumer */
            putfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.consumer:Ljava/util/function/Consumer;
         2: .line 890
            return
        end local 2 // java.util.function.Consumer consumer
        end local 1 // java.util.concurrent.CompletableFuture status
        end local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Ljava/util/concurrent/SubmissionPublisher$ConsumerSubscriber<TT;>;
            0    3     1    status  Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
            0    3     2  consumer  Ljava/util/function/Consumer<-TT;>;
    Signature: (Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;Ljava/util/function/Consumer<-TT;>;)V
    MethodParameters:
          Name  Flags
      status    
      consumer  

  public final void onSubscribe(java.util.concurrent.Flow$Subscription);
    descriptor: (Ljava/util/concurrent/Flow$Subscription;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
        start local 1 // java.util.concurrent.Flow$Subscription subscription
         0: .line 892
            aload 0 /* this */
            aload 1 /* subscription */
            putfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
         1: .line 893
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.status:Ljava/util/concurrent/CompletableFuture;
            aload 1 /* subscription */
            invokedynamic accept(Ljava/util/concurrent/Flow$Subscription;)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
                  java/util/concurrent/SubmissionPublisher$ConsumerSubscriber.lambda$0(Ljava/util/concurrent/Flow$Subscription;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Void;Ljava/lang/Throwable;)V
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
            pop
         2: .line 894
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.status:Ljava/util/concurrent/CompletableFuture;
            invokevirtual java.util.concurrent.CompletableFuture.isDone:()Z
            ifne 4
         3: .line 895
            aload 1 /* subscription */
            ldc 9223372036854775807
            invokeinterface java.util.concurrent.Flow$Subscription.request:(J)V
         4: .line 896
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.util.concurrent.Flow$Subscription subscription
        end local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Ljava/util/concurrent/SubmissionPublisher$ConsumerSubscriber<TT;>;
            0    5     1  subscription  Ljava/util/concurrent/Flow$Subscription;
    MethodParameters:
              Name  Flags
      subscription  

  public final void onError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
        start local 1 // java.lang.Throwable ex
         0: .line 898
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.status:Ljava/util/concurrent/CompletableFuture;
            aload 1 /* ex */
            invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
         1: .line 899
            return
        end local 1 // java.lang.Throwable ex
        end local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljava/util/concurrent/SubmissionPublisher$ConsumerSubscriber<TT;>;
            0    2     1    ex  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      ex    

  public final void onComplete();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
         0: .line 901
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.status:Ljava/util/concurrent/CompletableFuture;
            aconst_null
            invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
            pop
         1: .line 902
            return
        end local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljava/util/concurrent/SubmissionPublisher$ConsumerSubscriber<TT;>;

  public final void onNext();
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
        start local 1 // java.lang.Object item
         0: .line 905
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.consumer:Ljava/util/function/Consumer;
            aload 1 /* item */
            invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
         1: .line 906
            goto 5
      StackMap locals:
      StackMap stack: java.lang.Throwable
         2: astore 2 /* ex */
        start local 2 // java.lang.Throwable ex
         3: .line 907
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
            invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
         4: .line 908
            aload 0 /* this */
            getfield java.util.concurrent.SubmissionPublisher$ConsumerSubscriber.status:Ljava/util/concurrent/CompletableFuture;
            aload 2 /* ex */
            invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
        end local 2 // java.lang.Throwable ex
         5: .line 910
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object item
        end local 0 // java.util.concurrent.SubmissionPublisher$ConsumerSubscriber this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Ljava/util/concurrent/SubmissionPublisher$ConsumerSubscriber<TT;>;
            0    6     1  item  TT;
            3    5     2    ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
    Signature: (TT;)V
    MethodParameters:
      Name  Flags
      item  

  private static void lambda$0(java.util.concurrent.Flow$Subscription, java.lang.Void, java.lang.Throwable);
    descriptor: (Ljava/util/concurrent/Flow$Subscription;Ljava/lang/Void;Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=3, args_size=3
        start local 1 // java.lang.Void v
        start local 2 // java.lang.Throwable e
         0: .line 893
            aload 0
            invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
            return
        end local 2 // java.lang.Throwable e
        end local 1 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     v  Ljava/lang/Void;
            0    1     2     e  Ljava/lang/Throwable;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Ljava/util/concurrent/Flow$Subscriber<TT;>;
SourceFile: "SubmissionPublisher.java"
NestHost: java.util.concurrent.SubmissionPublisher
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  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
  final ConsumerSubscriber = java.util.concurrent.SubmissionPublisher$ConsumerSubscriber of java.util.concurrent.SubmissionPublisher