final class jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription implements java.util.concurrent.Flow$Subscription
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription
  super_class: java.lang.Object
{
  private final jdk.internal.net.http.common.Demand demand;
    descriptor: Ljdk/internal/net/http/common/Demand;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final jdk.internal.net.http.common.SequentialScheduler readScheduler;
    descriptor: Ljdk/internal/net/http/common/SequentialScheduler;
    flags: (0x0010) ACC_FINAL

  private volatile boolean completed;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private final jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadEvent readEvent;
    descriptor: Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadEvent;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final jdk.internal.net.http.AsyncEvent subscribeEvent;
    descriptor: Ljdk/internal/net/http/AsyncEvent;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final jdk.internal.net.http.SocketTube$InternalReadPublisher this$1;
    descriptor: Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  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 650
            ldc Ljdk/internal/net/http/SocketTube;
            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.SocketTube$InternalReadPublisher$InternalReadSubscription.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(jdk.internal.net.http.SocketTube$InternalReadPublisher);
    descriptor: (Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 658
            aload 0 /* this */
            aload 1
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 652
            aload 0 /* this */
            new jdk.internal.net.http.common.Demand
            dup
            invokespecial jdk.internal.net.http.common.Demand.<init>:()V
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.demand:Ljdk/internal/net/http/common/Demand;
         2: .line 659
            aload 0 /* this */
            new jdk.internal.net.http.common.SequentialScheduler
            dup
            new jdk.internal.net.http.SocketTube$SocketFlowTask
            dup
            aload 0 /* this */
            invokedynamic run(Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  jdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription.read()V (5)
                  ()V
            invokespecial jdk.internal.net.http.SocketTube$SocketFlowTask.<init>:(Ljava/lang/Runnable;)V
            invokespecial jdk.internal.net.http.common.SequentialScheduler.<init>:(Ljdk/internal/net/http/common/SequentialScheduler$RestartableTask;)V
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
         3: .line 660
            aload 0 /* this */
            new jdk.internal.net.http.AsyncTriggerEvent
            dup
            aload 0 /* this */
            invokedynamic accept(Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;)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/SocketTube$InternalReadPublisher$InternalReadSubscription.signalError(Ljava/lang/Throwable;)V (5)
                  (Ljava/io/IOException;)V
         4: .line 661
            aload 0 /* this */
            invokedynamic run(Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  jdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription.handleSubscribeEvent()V (5)
                  ()V
            invokespecial jdk.internal.net.http.AsyncTriggerEvent.<init>:(Ljava/util/function/Consumer;Ljava/lang/Runnable;)V
         5: .line 660
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.subscribeEvent:Ljdk/internal/net/http/AsyncEvent;
         6: .line 662
            aload 0 /* this */
            new jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadEvent
            dup
            aload 1
            aload 1
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.channel:Ljava/nio/channels/SocketChannel;
            aload 0 /* this */
            invokespecial jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadEvent.<init>:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;Ljava/nio/channels/SocketChannel;Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;)V
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readEvent:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadEvent;
         7: .line 663
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
    MethodParameters:
        Name  Flags
      this$0  final

  final void signalSubscribe();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 669
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifne 1
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
            ifeq 5
         1: .line 672
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 3
         2: .line 673
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "handling pending subscription while completed"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         3: .line 674
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
         4: .line 675
            goto 11
         5: .line 677
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 6
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "registering subscribe event"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         6: .line 678
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.client:Ljdk/internal/net/http/HttpClientImpl;
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.subscribeEvent:Ljdk/internal/net/http/AsyncEvent;
            invokevirtual jdk.internal.net.http.HttpClientImpl.registerEvent:(Ljdk/internal/net/http/AsyncEvent;)V
         7: .line 679
            goto 11
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: astore 1 /* t */
        start local 1 // java.lang.Throwable t
         9: .line 680
            aload 0 /* this */
            aload 1 /* t */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.signalError:(Ljava/lang/Throwable;)V
        10: .line 681
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        end local 1 // java.lang.Throwable t
        11: .line 684
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   12     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
            9   11     1     t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           5     7       8  Class java.lang.Throwable

  final void handleSubscribeEvent();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 687
            getstatic jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.client:Ljdk/internal/net/http/HttpClientImpl;
            invokevirtual jdk.internal.net.http.HttpClientImpl.isSelectorThread:()Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 688
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "subscribe event raised"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         2: .line 689
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 3
            ldc "Start reading from {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
         3: .line 690
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.runOrSchedule:()V
         4: .line 691
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifne 5
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
            ifeq 8
         5: .line 694
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 7
         6: .line 695
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "handling pending subscription when completed"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         7: .line 696
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
         8: .line 698
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;

  public final void request(long);
    descriptor: (J)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
        start local 1 // long n
         0: .line 710
            lload 1 /* n */
            lconst_0
            lcmp
            ifle 6
         1: .line 711
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.demand:Ljdk/internal/net/http/common/Demand;
            lload 1 /* n */
            invokevirtual jdk.internal.net.http.common.Demand.increase:(J)Z
            istore 3 /* wasFulfilled */
        start local 3 // boolean wasFulfilled
         2: .line 712
            iload 3 /* wasFulfilled */
            ifeq 7
         3: .line 713
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 4
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "got some demand for reading"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         4: .line 714
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.resumeReadEvent:()V
        end local 3 // boolean wasFulfilled
         5: .line 718
            goto 7
         6: .line 719
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new java.lang.IllegalArgumentException
            dup
            ldc "non-positive request"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.signalError:(Ljava/lang/Throwable;)V
         7: .line 721
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            new java.lang.StringBuilder
            dup
            ldc "leaving request("
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            lload 1 /* n */
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            ldc "): "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual jdk.internal.net.http.SocketTube.debugState:(Ljava/lang/String;)V
         8: .line 722
            return
        end local 1 // long n
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    9     0          this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
            0    9     1             n  J
            2    5     3  wasFulfilled  Z
    MethodParameters:
      Name  Flags
      n     

  public final void cancel();
    descriptor: ()V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 726
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.pauseReadEvent:()V
         1: .line 727
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 5
         2: .line 728
            ldc "Read subscription cancelled for channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
         3: .line 729
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
         4: .line 728
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
         5: .line 731
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.stop:()V
         6: .line 732
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;

  private void resumeReadEvent();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 735
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 1
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "resuming read event"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         1: .line 736
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readEvent:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadEvent;
            aload 0 /* this */
            invokedynamic accept(Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;)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/SocketTube$InternalReadPublisher$InternalReadSubscription.signalError(Ljava/lang/Throwable;)V (5)
                  (Ljava/lang/Throwable;)V
            invokevirtual jdk.internal.net.http.SocketTube.resumeEvent:(Ljdk/internal/net/http/SocketTube$SocketFlowEvent;Ljava/util/function/Consumer;)V
         2: .line 737
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;

  private void pauseReadEvent();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 740
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 1
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "pausing read event"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         1: .line 741
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readEvent:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadEvent;
            aload 0 /* this */
            invokedynamic accept(Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;)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/SocketTube$InternalReadPublisher$InternalReadSubscription.signalError(Ljava/lang/Throwable;)V (5)
                  (Ljava/lang/Throwable;)V
            invokevirtual jdk.internal.net.http.SocketTube.pauseEvent:(Ljdk/internal/net/http/SocketTube$SocketFlowEvent;Ljava/util/function/Consumer;)V
         2: .line 742
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;

  final void handleError();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 746
            getstatic jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            ifnonnull 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 747
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.runOrSchedule:()V
         2: .line 748
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;

  final void signalError(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
        start local 1 // java.lang.Throwable error
         0: .line 751
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            aload 1 /* error */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifne 2
         1: .line 752
            return
         2: .line 754
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 3
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            new java.lang.StringBuilder
            dup
            ldc "got read error: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* error */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         3: .line 755
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 7
         4: .line 756
            ldc "Read error signalled on channel {0}: {1}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
         5: .line 757
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            dup
            iconst_1
            aload 1 /* error */
            aastore
         6: .line 756
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
         7: .line 759
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.runOrSchedule:()V
         8: .line 760
            return
        end local 1 // java.lang.Throwable error
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    9     0   this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
            0    9     1  error  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      error  

  final void signalReadable();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 763
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.runOrSchedule:()V
         1: .line 764
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;

  final void read();
    descriptor: ()V
    flags: (0x0010) ACC_FINAL
    Code:
      stack=6, locals=6, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 775
            goto 103
         1: .line 776
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
            ifeq 8
         2: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 6
         3: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 4
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
         4: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 6
         5: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
         6: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
         7: .line 776
            return
         8: .line 779
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            ifeq 17
         9: .line 780
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 11
        10: .line 781
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "pending subscriber subscribed"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        11: .line 890
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 15
        12: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 13
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        13: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 15
        14: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        15: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        16: .line 782
            return
        17: .line 788
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher.subscription:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadSubscription;
            astore 1 /* current */
        start local 1 // jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription current
        18: .line 789
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.lang.Throwable
            astore 2 /* error */
        start local 2 // java.lang.Throwable error
        19: .line 790
            aload 1 /* current */
            ifnonnull 31
        20: .line 791
            getstatic jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.$assertionsDisabled:Z
            ifne 21
            aload 2 /* error */
            ifnonnull 21
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        21: .line 792
      StackMap locals: jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 25
        22: .line 793
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "error raised before subscriber subscribed: %s"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
        23: .line 794
            aload 2 /* error */
            aastore
        24: .line 793
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;[Ljava/lang/Object;)V
        25: .line 890
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 29
        26: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 27
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        27: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 29
        28: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        29: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        30: .line 795
            return
        31: .line 797
      StackMap locals:
      StackMap stack:
            aload 1 /* current */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.subscriber:Ljdk/internal/net/http/common/FlowTube$TubeSubscriber;
            astore 3 /* subscriber */
        start local 3 // jdk.internal.net.http.common.FlowTube$TubeSubscriber subscriber
        32: .line 798
            aload 2 /* error */
            ifnull 53
        33: .line 799
            aload 0 /* this */
            iconst_1
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
        34: .line 801
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.pauseReadEvent:()V
        35: .line 802
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 39
        36: .line 803
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Sending error "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* error */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
        37: .line 804
            ldc " to subscriber "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* subscriber */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        38: .line 803
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        39: .line 805
      StackMap locals: jdk.internal.net.http.common.FlowTube$TubeSubscriber
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 43
        40: .line 806
            ldc "Raising error with subscriber for {0}: {1}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
        41: .line 807
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            dup
            iconst_1
            aload 2 /* error */
            aastore
        42: .line 806
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        43: .line 809
      StackMap locals:
      StackMap stack:
            aload 1 /* current */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            aload 2 /* error */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            pop
        44: .line 810
            aload 1 /* current */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.signalCompletion:()V
        45: .line 811
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.stop:()V
        46: .line 812
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            ldc "leaving read() loop with error: "
            invokevirtual jdk.internal.net.http.SocketTube.debugState:(Ljava/lang/String;)V
        47: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 51
        48: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 49
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        49: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 51
        50: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        51: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        52: .line 813
            return
        53: .line 817
      StackMap locals:
      StackMap stack:
            getstatic jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.$assertionsDisabled:Z
            ifne 54
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.client:Ljdk/internal/net/http/HttpClientImpl;
            invokevirtual jdk.internal.net.http.HttpClientImpl.isSelectorThread:()Z
            ifne 54
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        54: .line 818
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.demand:Ljdk/internal/net/http/common/Demand;
            invokevirtual jdk.internal.net.http.common.Demand.tryDecrement:()Z
            ifeq 100
        55: .line 821
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            aload 1 /* current */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.bufferSource:Ljdk/internal/net/http/SocketTube$BufferSource;
            invokevirtual jdk.internal.net.http.SocketTube.readAvailable:(Ljdk/internal/net/http/SocketTube$BufferSource;)Ljava/util/List;
            astore 4 /* bytes */
        start local 4 // java.util.List bytes
        56: .line 822
            aload 4 /* bytes */
            getstatic jdk.internal.net.http.SocketTube.EOF:Ljava/util/List;
            if_acmpne 74
        57: .line 823
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
            ifne 67
        58: .line 824
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 59
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "got read EOF"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        59: .line 825
      StackMap locals: java.util.List
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 63
        60: .line 826
            ldc "EOF read from channel: {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
        61: .line 827
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
        62: .line 826
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        63: .line 829
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
        64: .line 832
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.pauseReadEvent:()V
        65: .line 833
            aload 1 /* current */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.signalCompletion:()V
        66: .line 834
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.stop:()V
        67: .line 836
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            ldc "leaving read() loop after EOF: "
            invokevirtual jdk.internal.net.http.SocketTube.debugState:(Ljava/lang/String;)V
        68: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 72
        69: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 70
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        70: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 72
        71: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        72: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        73: .line 837
            return
        74: .line 838
      StackMap locals:
      StackMap stack:
            aload 4 /* bytes */
            invokestatic jdk.internal.net.http.common.Utils.remaining:(Ljava/util/List;)J
            lconst_0
            lcmp
            ifle 87
        75: .line 841
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 77
        76: .line 842
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            new java.lang.StringBuilder
            dup
            ldc "read bytes: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 4 /* bytes */
            invokestatic jdk.internal.net.http.common.Utils.remaining:(Ljava/util/List;)J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        77: .line 843
      StackMap locals:
      StackMap stack:
            getstatic jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.$assertionsDisabled:Z
            ifne 78
            aload 1 /* current */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.completed:Z
            ifeq 78
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        78: .line 844
      StackMap locals:
      StackMap stack:
            aload 3 /* subscriber */
            aload 4 /* bytes */
            invokeinterface jdk.internal.net.http.common.FlowTube$TubeSubscriber.onNext:(Ljava/lang/Object;)V
        79: .line 852
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.resumeReadEvent:()V
        80: .line 853
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            ldc "leaving read() loop after onNext: "
            invokevirtual jdk.internal.net.http.SocketTube.debugState:(Ljava/lang/String;)V
        81: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 85
        82: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 83
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        83: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 85
        84: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        85: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        86: .line 854
            return
        87: .line 857
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 88
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "no more bytes available"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        88: .line 862
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.demand:Ljdk/internal/net/http/common/Demand;
            lconst_1
            invokevirtual jdk.internal.net.http.common.Demand.increase:(J)Z
            pop
        89: .line 863
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.resumeReadEvent:()V
        90: .line 864
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            ldc "leaving read() loop with no bytes"
            invokevirtual jdk.internal.net.http.SocketTube.debugState:(Ljava/lang/String;)V
        91: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 95
        92: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 93
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        93: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 95
        94: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
        95: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
        96: .line 865
            return
        end local 4 // java.util.List bytes
        97: .line 867
      StackMap locals: jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription java.lang.Throwable jdk.internal.net.http.common.FlowTube$TubeSubscriber
      StackMap stack: java.lang.Throwable
            astore 4 /* x */
        start local 4 // java.lang.Throwable x
        98: .line 868
            aload 0 /* this */
            aload 4 /* x */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.signalError:(Ljava/lang/Throwable;)V
        99: .line 869
            goto 103
        end local 4 // java.lang.Throwable x
       100: .line 872
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 101
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "no more demand for reading"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
       101: .line 882
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            ldc "leaving read() loop with no demand"
            invokevirtual jdk.internal.net.http.SocketTube.debugState:(Ljava/lang/String;)V
       102: .line 883
            goto 120
        end local 3 // jdk.internal.net.http.common.FlowTube$TubeSubscriber subscriber
        end local 2 // java.lang.Throwable error
        end local 1 // jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription current
       103: .line 775
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 1
       104: .line 886
            goto 120
      StackMap locals:
      StackMap stack: java.lang.Throwable
       105: astore 1 /* t */
        start local 1 // java.lang.Throwable t
       106: .line 887
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 107
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Unexpected exception in read loop"
            aload 1 /* t */
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;Ljava/lang/Throwable;)V
       107: .line 888
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            aload 1 /* t */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.signalError:(Ljava/lang/Throwable;)V
        end local 1 // java.lang.Throwable t
       108: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 112
       109: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 110
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
       110: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 112
       111: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
       112: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
            goto 125
       113: .line 889
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 5
       114: .line 890
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 118
       115: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 116
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
       116: .line 892
      StackMap locals: jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription top top top top java.lang.Throwable
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 118
       117: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
       118: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
       119: .line 897
            aload 5
            athrow
       120: .line 890
      StackMap locals: jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifeq 124
       121: .line 891
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 122
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "Read scheduler stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
       122: .line 892
      StackMap locals:
      StackMap stack:
            invokestatic jdk.internal.net.http.common.Log.channel:()Z
            ifeq 124
       123: .line 893
            ldc "Stopped reading from channel {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            invokevirtual jdk.internal.net.http.SocketTube.channelDescr:()Ljava/lang/String;
            aastore
            invokestatic jdk.internal.net.http.common.Log.logChannel:(Ljava/lang/String;[Ljava/lang/Object;)V
       124: .line 896
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.handlePending:()Z
            pop
       125: .line 898
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0  126     0        this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
           18  103     1     current  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadSubscription;
           19  103     2       error  Ljava/lang/Throwable;
           32  103     3  subscriber  Ljdk/internal/net/http/common/FlowTube$TubeSubscriber;
           56   97     4       bytes  Ljava/util/List<Ljava/nio/ByteBuffer;>;
           98  100     4           x  Ljava/lang/Throwable;
          106  108     1           t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          55    68      97  Class java.lang.Throwable
          74    81      97  Class java.lang.Throwable
          87    91      97  Class java.lang.Throwable
           0     2     105  Class java.lang.Throwable
           8    11     105  Class java.lang.Throwable
          17    25     105  Class java.lang.Throwable
          31    47     105  Class java.lang.Throwable
          53    68     105  Class java.lang.Throwable
          74    81     105  Class java.lang.Throwable
          87    91     105  Class java.lang.Throwable
          97   104     105  Class java.lang.Throwable
           0     2     113  any
           8    11     113  any
          17    25     113  any
          31    47     113  any
          53    68     113  any
          74    81     113  any
          87    91     113  any
          97   108     113  any

  boolean handlePending();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=6, locals=3, args_size=1
        start local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
         0: .line 901
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher.pendingSubscription:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription
            astore 1 /* pending */
        start local 1 // jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription pending
         1: .line 902
            aload 1 /* pending */
            ifnonnull 2
            iconst_0
            ireturn
         2: .line 903
      StackMap locals: jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 6
         3: .line 904
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "handling pending subscription for %s"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
         4: .line 905
            aload 1 /* pending */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.subscriber:Ljdk/internal/net/http/common/FlowTube$TubeSubscriber;
            aastore
         5: .line 904
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;[Ljava/lang/Object;)V
         6: .line 906
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher.subscription:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadSubscription;
            astore 2 /* current */
        start local 2 // jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription current
         7: .line 907
            aload 2 /* current */
            ifnull 9
            aload 2 /* current */
            aload 1 /* pending */
            if_acmpeq 9
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
            ifne 9
         8: .line 908
            aload 2 /* current */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.subscriber:Ljdk/internal/net/http/common/FlowTube$TubeSubscriber;
            invokeinterface jdk.internal.net.http.common.FlowTube$TubeSubscriber.dropSubscription:()V
         9: .line 910
      StackMap locals: jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 10
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "read demand reset to 0"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        10: .line 911
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher.subscriptionImpl:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.demand:Ljdk/internal/net/http/common/Demand;
            invokevirtual jdk.internal.net.http.common.Demand.reset:()V
        11: .line 912
            aload 1 /* pending */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.lang.Throwable
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            pop
        12: .line 913
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.readScheduler:Ljdk/internal/net/http/common/SequentialScheduler;
            invokevirtual jdk.internal.net.http.common.SequentialScheduler.isStopped:()Z
            ifne 15
        13: .line 914
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            aload 1 /* pending */
            putfield jdk.internal.net.http.SocketTube$InternalReadPublisher.subscription:Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadSubscription;
        14: .line 915
            goto 16
        15: .line 916
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 16
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "socket tube is already stopped"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        16: .line 918
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            invokeinterface jdk.internal.net.http.common.Logger.on:()Z
            ifeq 17
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.debug:Ljdk/internal/net/http/common/Logger;
            ldc "calling onSubscribe"
            invokeinterface jdk.internal.net.http.common.Logger.log:(Ljava/lang/String;)V
        17: .line 919
      StackMap locals:
      StackMap stack:
            aload 1 /* pending */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.signalOnSubscribe:()V
        18: .line 920
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.completed:Z
            ifeq 21
        19: .line 921
            aload 1 /* pending */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            aload 0 /* this */
            getfield jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription.this$1:Ljdk/internal/net/http/SocketTube$InternalReadPublisher;
            invokestatic jdk.internal.net.http.SocketTube$InternalReadPublisher.access$0:(Ljdk/internal/net/http/SocketTube$InternalReadPublisher;)Ljdk/internal/net/http/SocketTube;
            getfield jdk.internal.net.http.SocketTube.errorRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.lang.Throwable
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            pop
        20: .line 922
            aload 1 /* pending */
            invokevirtual jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription.signalCompletion:()V
        21: .line 924
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 2 // jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription current
        end local 1 // jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription pending
        end local 0 // jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   22     0     this  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$InternalReadSubscription;
            1   22     1  pending  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadSubscription;
            7   22     2  current  Ljdk/internal/net/http/SocketTube$InternalReadPublisher$ReadSubscription;
}
SourceFile: "SocketTube.java"
NestHost: jdk.internal.net.http.SocketTube
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
  public abstract BufferSource = jdk.internal.net.http.SocketTube$BufferSource of jdk.internal.net.http.SocketTube
  private final InternalReadPublisher = jdk.internal.net.http.SocketTube$InternalReadPublisher of jdk.internal.net.http.SocketTube
  final InternalReadSubscription = jdk.internal.net.http.SocketTube$InternalReadPublisher$InternalReadSubscription of jdk.internal.net.http.SocketTube$InternalReadPublisher
  final ReadEvent = jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadEvent of jdk.internal.net.http.SocketTube$InternalReadPublisher
  final ReadSubscription = jdk.internal.net.http.SocketTube$InternalReadPublisher$ReadSubscription of jdk.internal.net.http.SocketTube$InternalReadPublisher
  private abstract SocketFlowEvent = jdk.internal.net.http.SocketTube$SocketFlowEvent of jdk.internal.net.http.SocketTube
  private SocketFlowTask = jdk.internal.net.http.SocketTube$SocketFlowTask of jdk.internal.net.http.SocketTube
  public abstract TubeSubscriber = jdk.internal.net.http.common.FlowTube$TubeSubscriber of jdk.internal.net.http.common.FlowTube
  public abstract RestartableTask = jdk.internal.net.http.common.SequentialScheduler$RestartableTask of jdk.internal.net.http.common.SequentialScheduler