http://micronaut.io: Natively Cloud Native
  • Graeme Rocher 
class io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription implements org.reactivestreams.Subscription
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription
  super_class: java.lang.Object
{
  final io.micronaut.http.netty.reactive.HandlerPublisher this$0;
    descriptor: Lio/micronaut/http/netty/reactive/HandlerPublisher;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  private static volatile int[] $SWITCH_TABLE$io$micronaut$http$netty$reactive$HandlerPublisher$State;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  private void <init>(io.micronaut.http.netty.reactive.HandlerPublisher);
    descriptor: (Lio/micronaut/http/netty/reactive/HandlerPublisher;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
         0: .line 470
            aload 0 /* this */
            aload 1
            putfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;
    MethodParameters:
        Name  Flags
      this$0  final

  public void request(long);
    descriptor: (J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
        start local 1 // long demand
         0: .line 474
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.executor:Lio/netty/util/concurrent/EventExecutor;
            aload 0 /* this */
            lload 1 /* demand */
            invokedynamic run(Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;J)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
                  io/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription.lambda$0(J)V (7)
                  ()V
            invokeinterface io.netty.util.concurrent.EventExecutor.execute:(Ljava/lang/Runnable;)V
         1: .line 475
            return
        end local 1 // long demand
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;
            0    2     1  demand  J
    MethodParameters:
        Name  Flags
      demand  final

  public void cancel();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
         0: .line 479
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.executor:Lio/netty/util/concurrent/EventExecutor;
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            invokedynamic run(Lio/micronaut/http/netty/reactive/HandlerPublisher;)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
                  io/micronaut/http/netty/reactive/HandlerPublisher.access$0(Lio/micronaut/http/netty/reactive/HandlerPublisher;)V (6)
                  ()V
            invokeinterface io.netty.util.concurrent.EventExecutor.execute:(Ljava/lang/Runnable;)V
         1: .line 480
            return
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;

  private void flushBuffer();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
         0: .line 483
            goto 4
         1: .line 484
      StackMap locals:
      StackMap stack:
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
            ifeq 3
         2: .line 485
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher.LOG:Lorg/slf4j/Logger;
            ldc "HandlerPublisher (state: {}) release message from buffer to satisfy demand: {}"
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         3: .line 487
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.buffer:Ljava/util/Queue;
            invokeinterface java.util.Queue.remove:()Ljava/lang/Object;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher.publishMessage:(Ljava/lang/Object;)V
         4: .line 483
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.buffer:Ljava/util/Queue;
            invokeinterface java.util.Queue.isEmpty:()Z
            ifne 5
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            lconst_0
            lcmp
            ifgt 1
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            ldc 9223372036854775807
            lcmp
            ifeq 1
         5: .line 489
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.buffer:Ljava/util/Queue;
            invokeinterface java.util.Queue.isEmpty:()Z
            ifeq 13
         6: .line 490
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            lconst_0
            lcmp
            ifle 11
         7: .line 491
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.BUFFERING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            if_acmpne 9
         8: .line 492
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.DEMANDING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            putfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
         9: .line 494
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher.requestDemand:()V
        10: .line 495
            goto 13
      StackMap locals:
      StackMap stack:
        11: aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.BUFFERING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            if_acmpne 13
        12: .line 496
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.IDLE:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            putfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
        13: .line 499
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   14     0  this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;

  private void illegalDemand();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
         0: .line 502
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher.cleanup:()V
         1: .line 503
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.subscriber:Lorg/reactivestreams/Subscriber;
            new java.lang.IllegalArgumentException
            dup
            ldc "Request for 0 or negative elements in violation of Section 3.9 of the Reactive Streams specification"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
         2: .line 504
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
            pop
         3: .line 505
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.DONE:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            putfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
         4: .line 506
            return
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;

  private boolean addDemand(long);
    descriptor: (J)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
        start local 1 // long demand
         0: .line 510
            lload 1 /* demand */
            lconst_0
            lcmp
            ifgt 3
         1: .line 511
            aload 0 /* this */
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.illegalDemand:()V
         2: .line 512
            iconst_0
            ireturn
         3: .line 514
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            ldc 9223372036854775807
            lcmp
            ifge 7
         4: .line 515
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            dup
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            lload 1 /* demand */
            ladd
            putfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
         5: .line 516
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
            lconst_0
            lcmp
            ifge 7
         6: .line 517
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            ldc 9223372036854775807
            putfield io.micronaut.http.netty.reactive.HandlerPublisher.outstandingDemand:J
         7: .line 520
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 1 // long demand
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;
            0    8     1  demand  J
    MethodParameters:
        Name  Flags
      demand  

  private void receivedDemand(long);
    descriptor: (J)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
        start local 1 // long demand
         0: .line 525
            invokestatic io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.$SWITCH_TABLE$io$micronaut$http$netty$reactive$HandlerPublisher$State:()[I
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            iaload
            tableswitch { // 5 - 8
                    5: 6
                    6: 1
                    7: 1
                    8: 1
              default: 11
          }
         1: .line 529
      StackMap locals:
      StackMap stack:
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
            ifeq 3
         2: .line 530
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher.LOG:Lorg/slf4j/Logger;
            ldc "HandlerPublisher (state: {}) received demand: {}"
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            lload 1 /* demand */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         3: .line 533
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 1 /* demand */
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.addDemand:(J)Z
            ifeq 11
         4: .line 534
            aload 0 /* this */
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.flushBuffer:()V
         5: .line 536
            goto 11
         6: .line 539
      StackMap locals:
      StackMap stack:
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher.LOG:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
            ifeq 8
         7: .line 540
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher.LOG:Lorg/slf4j/Logger;
            ldc "HandlerPublisher (state: {}) received demand: {}"
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            lload 1 /* demand */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         8: .line 543
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 1 /* demand */
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.addDemand:(J)Z
            ifeq 11
         9: .line 546
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.DEMANDING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            putfield io.micronaut.http.netty.reactive.HandlerPublisher.state:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
        10: .line 547
            aload 0 /* this */
            getfield io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.this$0:Lio/micronaut/http/netty/reactive/HandlerPublisher;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher.requestDemand:()V
        11: .line 553
      StackMap locals:
      StackMap stack:
            return
        end local 1 // long demand
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   12     0    this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;
            0   12     1  demand  J
    MethodParameters:
        Name  Flags
      demand  

  static int[] $SWITCH_TABLE$io$micronaut$http$netty$reactive$HandlerPublisher$State();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 470
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.$SWITCH_TABLE$io$micronaut$http$netty$reactive$HandlerPublisher$State:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic io.micronaut.http.netty.reactive.HandlerPublisher$State.values:()[Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.BUFFERING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            bipush 6
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.DEMANDING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            bipush 7
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.DONE:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            bipush 9
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.DRAINING:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            bipush 8
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.IDLE:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            iconst_5
            iastore
        15: goto 17
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        16: pop
      StackMap locals:
      StackMap stack:
        17: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.NO_CONTEXT:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            iconst_2
            iastore
        18: goto 20
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        19: pop
      StackMap locals:
      StackMap stack:
        20: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.NO_SUBSCRIBER:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            iconst_3
            iastore
        21: goto 23
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        22: pop
      StackMap locals:
      StackMap stack:
        23: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.NO_SUBSCRIBER_ERROR:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            iconst_4
            iastore
        24: goto 26
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        25: pop
      StackMap locals:
      StackMap stack:
        26: aload 0
            getstatic io.micronaut.http.netty.reactive.HandlerPublisher$State.NO_SUBSCRIBER_OR_CONTEXT:Lio/micronaut/http/netty/reactive/HandlerPublisher$State;
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$State.ordinal:()I
            iconst_1
            iastore
        27: goto 29
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        28: pop
      StackMap locals:
      StackMap stack:
        29: aload 0
            dup
            putstatic io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.$SWITCH_TABLE$io$micronaut$http$netty$reactive$HandlerPublisher$State:[I
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.NoSuchFieldError
           5     6       7  Class java.lang.NoSuchFieldError
           8     9      10  Class java.lang.NoSuchFieldError
          11    12      13  Class java.lang.NoSuchFieldError
          14    15      16  Class java.lang.NoSuchFieldError
          17    18      19  Class java.lang.NoSuchFieldError
          20    21      22  Class java.lang.NoSuchFieldError
          23    24      25  Class java.lang.NoSuchFieldError
          26    27      28  Class java.lang.NoSuchFieldError

  private void lambda$0(long);
    descriptor: (J)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
         0: .line 474
            aload 0 /* this */
            lload 1
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription.receivedDemand:(J)V
            return
        end local 0 // io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/micronaut/http/netty/reactive/HandlerPublisher$ChannelSubscription;
}
SourceFile: "HandlerPublisher.java"
NestHost: io.micronaut.http.netty.reactive.HandlerPublisher
InnerClasses:
  private ChannelSubscription = io.micronaut.http.netty.reactive.HandlerPublisher$ChannelSubscription of io.micronaut.http.netty.reactive.HandlerPublisher
  final State = io.micronaut.http.netty.reactive.HandlerPublisher$State of io.micronaut.http.netty.reactive.HandlerPublisher
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles