class org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher extends org.springframework.http.server.reactive.AbstractListenerReadPublisher<org.springframework.core.io.buffer.DataBuffer>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher
  super_class: org.springframework.http.server.reactive.AbstractListenerReadPublisher
{
  private final org.xnio.channels.StreamSourceChannel channel;
    descriptor: Lorg/xnio/channels/StreamSourceChannel;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.springframework.core.io.buffer.DataBufferFactory bufferFactory;
    descriptor: Lorg/springframework/core/io/buffer/DataBufferFactory;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.undertow.connector.ByteBufferPool byteBufferPool;
    descriptor: Lio/undertow/connector/ByteBufferPool;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final org.springframework.http.server.reactive.UndertowServerHttpRequest this$0;
    descriptor: Lorg/springframework/http/server/reactive/UndertowServerHttpRequest;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  public void <init>(org.springframework.http.server.reactive.UndertowServerHttpRequest, io.undertow.server.HttpServerExchange, org.springframework.core.io.buffer.DataBufferFactory);
    descriptor: (Lorg/springframework/http/server/reactive/UndertowServerHttpRequest;Lio/undertow/server/HttpServerExchange;Lorg/springframework/core/io/buffer/DataBufferFactory;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=4
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
        start local 2 // io.undertow.server.HttpServerExchange exchange
        start local 3 // org.springframework.core.io.buffer.DataBufferFactory bufferFactory
         0: .line 143
            aload 0 /* this */
            aload 1
            putfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.this$0:Lorg/springframework/http/server/reactive/UndertowServerHttpRequest;
         1: .line 144
            aload 0 /* this */
            aload 1
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest.getLogPrefix:()Ljava/lang/String;
            invokespecial org.springframework.http.server.reactive.AbstractListenerReadPublisher.<init>:(Ljava/lang/String;)V
         2: .line 145
            aload 0 /* this */
            aload 2 /* exchange */
            invokevirtual io.undertow.server.HttpServerExchange.getRequestChannel:()Lorg/xnio/channels/StreamSourceChannel;
            putfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
         3: .line 146
            aload 0 /* this */
            aload 3 /* bufferFactory */
            putfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
         4: .line 147
            aload 0 /* this */
            aload 2 /* exchange */
            invokevirtual io.undertow.server.HttpServerExchange.getConnection:()Lio/undertow/server/ServerConnection;
            invokevirtual io.undertow.server.ServerConnection.getByteBufferPool:()Lio/undertow/connector/ByteBufferPool;
            putfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.byteBufferPool:Lio/undertow/connector/ByteBufferPool;
         5: .line 148
            return
        end local 3 // org.springframework.core.io.buffer.DataBufferFactory bufferFactory
        end local 2 // io.undertow.server.HttpServerExchange exchange
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    6     0           this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;
            0    6     2       exchange  Lio/undertow/server/HttpServerExchange;
            0    6     3  bufferFactory  Lorg/springframework/core/io/buffer/DataBufferFactory;
    MethodParameters:
               Name  Flags
      this$0         final
      exchange       
      bufferFactory  

  private void registerListeners(io.undertow.server.HttpServerExchange);
    descriptor: (Lio/undertow/server/HttpServerExchange;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
        start local 1 // io.undertow.server.HttpServerExchange exchange
         0: .line 151
            aload 1 /* exchange */
            aload 0 /* this */
            invokedynamic exchangeEvent(Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;)Lio/undertow/server/ExchangeCompletionListener;
              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:
                  (Lio/undertow/server/HttpServerExchange;Lio/undertow/server/ExchangeCompletionListener$NextListener;)V
                  org/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher.lambda$0(Lio/undertow/server/HttpServerExchange;Lio/undertow/server/ExchangeCompletionListener$NextListener;)V (7)
                  (Lio/undertow/server/HttpServerExchange;Lio/undertow/server/ExchangeCompletionListener$NextListener;)V
            invokevirtual io.undertow.server.HttpServerExchange.addExchangeCompleteListener:(Lio/undertow/server/ExchangeCompletionListener;)Lio/undertow/server/HttpServerExchange;
            pop
         1: .line 155
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
            invokeinterface org.xnio.channels.StreamSourceChannel.getReadSetter:()Lorg/xnio/ChannelListener$Setter;
            aload 0 /* this */
            invokedynamic handleEvent(Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;)Lorg/xnio/ChannelListener;
              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/nio/channels/Channel;)V
                  org/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher.lambda$1(Lorg/xnio/channels/StreamSourceChannel;)V (7)
                  (Lorg/xnio/channels/StreamSourceChannel;)V
            invokeinterface org.xnio.ChannelListener$Setter.set:(Lorg/xnio/ChannelListener;)V
         2: .line 156
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
            invokeinterface org.xnio.channels.StreamSourceChannel.getCloseSetter:()Lorg/xnio/ChannelListener$Setter;
            aload 0 /* this */
            invokedynamic handleEvent(Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;)Lorg/xnio/ChannelListener;
              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/nio/channels/Channel;)V
                  org/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher.lambda$2(Lorg/xnio/channels/StreamSourceChannel;)V (7)
                  (Lorg/xnio/channels/StreamSourceChannel;)V
            invokeinterface org.xnio.ChannelListener$Setter.set:(Lorg/xnio/ChannelListener;)V
         3: .line 157
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
            invokeinterface org.xnio.channels.StreamSourceChannel.resumeReads:()V
         4: .line 158
            return
        end local 1 // io.undertow.server.HttpServerExchange exchange
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;
            0    5     1  exchange  Lio/undertow/server/HttpServerExchange;
    MethodParameters:
          Name  Flags
      exchange  

  protected void checkOnDataAvailable();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
         0: .line 162
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
            invokeinterface org.xnio.channels.StreamSourceChannel.resumeReads:()V
         1: .line 164
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.onDataAvailable:()V
         2: .line 165
            return
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;

  protected void readingPaused();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
         0: .line 169
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
            invokeinterface org.xnio.channels.StreamSourceChannel.suspendReads:()V
         1: .line 170
            return
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;

  protected org.springframework.core.io.buffer.DataBuffer read();
    descriptor: ()Lorg/springframework/core/io/buffer/DataBuffer;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=8, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
         0: .line 175
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.byteBufferPool:Lio/undertow/connector/ByteBufferPool;
            invokeinterface io.undertow.connector.ByteBufferPool.allocate:()Lio/undertow/connector/PooledByteBuffer;
            astore 1 /* pooledByteBuffer */
        start local 1 // io.undertow.connector.PooledByteBuffer pooledByteBuffer
         1: .line 176
            iconst_1
            istore 2 /* release */
        start local 2 // boolean release
         2: .line 178
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.getBuffer:()Ljava/nio/ByteBuffer;
            astore 3 /* byteBuffer */
        start local 3 // java.nio.ByteBuffer byteBuffer
         3: .line 179
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.channel:Lorg/xnio/channels/StreamSourceChannel;
            aload 3 /* byteBuffer */
            invokeinterface org.xnio.channels.StreamSourceChannel.read:(Ljava/nio/ByteBuffer;)I
            istore 4 /* read */
        start local 4 // int read
         4: .line 181
            getstatic org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.rsReadLogger:Lorg/apache/commons/logging/Log;
            invokeinterface org.apache.commons.logging.Log.isTraceEnabled:()Z
            ifeq 8
         5: .line 182
            getstatic org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.rsReadLogger:Lorg/apache/commons/logging/Log;
            new java.lang.StringBuilder
            dup
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.getLogPrefix:()Ljava/lang/String;
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "Read "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            iload 4 /* read */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            iload 4 /* read */
            iconst_m1
            if_icmpeq 6
            ldc " bytes"
            goto 7
      StackMap locals: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher io.undertow.connector.PooledByteBuffer int java.nio.ByteBuffer int
      StackMap stack: org.apache.commons.logging.Log java.lang.StringBuilder
         6: ldc ""
      StackMap locals: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher io.undertow.connector.PooledByteBuffer int java.nio.ByteBuffer int
      StackMap stack: org.apache.commons.logging.Log java.lang.StringBuilder java.lang.String
         7: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface org.apache.commons.logging.Log.trace:(Ljava/lang/Object;)V
         8: .line 185
      StackMap locals:
      StackMap stack:
            iload 4 /* read */
            ifle 16
         9: .line 186
            aload 3 /* byteBuffer */
            invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
            pop
        10: .line 187
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
            aload 3 /* byteBuffer */
            invokeinterface org.springframework.core.io.buffer.DataBufferFactory.wrap:(Ljava/nio/ByteBuffer;)Lorg/springframework/core/io/buffer/DataBuffer;
            astore 5 /* dataBuffer */
        start local 5 // org.springframework.core.io.buffer.DataBuffer dataBuffer
        11: .line 188
            iconst_0
            istore 2 /* release */
        12: .line 189
            new org.springframework.http.server.reactive.UndertowServerHttpRequest$UndertowDataBuffer
            dup
            aload 5 /* dataBuffer */
            aload 1 /* pooledByteBuffer */
            invokespecial org.springframework.http.server.reactive.UndertowServerHttpRequest$UndertowDataBuffer.<init>:(Lorg/springframework/core/io/buffer/DataBuffer;Lio/undertow/connector/PooledByteBuffer;)V
            astore 7
        13: .line 197
            iload 2 /* release */
            ifeq 15
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.isOpen:()Z
            ifeq 15
        14: .line 198
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        15: .line 189
      StackMap locals: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher io.undertow.connector.PooledByteBuffer int java.nio.ByteBuffer int org.springframework.core.io.buffer.DataBuffer top org.springframework.core.io.buffer.DataBuffer
      StackMap stack:
            aload 7
            areturn
        end local 5 // org.springframework.core.io.buffer.DataBuffer dataBuffer
        16: .line 191
      StackMap locals: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher io.undertow.connector.PooledByteBuffer int java.nio.ByteBuffer int
      StackMap stack:
            iload 4 /* read */
            iconst_m1
            if_icmpne 18
        17: .line 192
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.onAllDataRead:()V
        18: .line 197
      StackMap locals:
      StackMap stack:
            iload 2 /* release */
            ifeq 20
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.isOpen:()Z
            ifeq 20
        19: .line 198
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        20: .line 194
      StackMap locals:
      StackMap stack:
            aconst_null
            areturn
        end local 4 // int read
        end local 3 // java.nio.ByteBuffer byteBuffer
        21: .line 196
      StackMap locals: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher io.undertow.connector.PooledByteBuffer int
      StackMap stack: java.lang.Throwable
            astore 6
        22: .line 197
            iload 2 /* release */
            ifeq 24
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.isOpen:()Z
            ifeq 24
        23: .line 198
            aload 1 /* pooledByteBuffer */
            invokeinterface io.undertow.connector.PooledByteBuffer.close:()V
        24: .line 200
      StackMap locals: org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher io.undertow.connector.PooledByteBuffer int top top top java.lang.Throwable
      StackMap stack:
            aload 6
            athrow
        end local 2 // boolean release
        end local 1 // io.undertow.connector.PooledByteBuffer pooledByteBuffer
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   25     0              this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;
            1   25     1  pooledByteBuffer  Lio/undertow/connector/PooledByteBuffer;
            2   25     2           release  Z
            3   21     3        byteBuffer  Ljava/nio/ByteBuffer;
            4   21     4              read  I
           11   16     5        dataBuffer  Lorg/springframework/core/io/buffer/DataBuffer;
      Exception table:
        from    to  target  type
           2    13      21  any
          16    18      21  any
    Exceptions:
      throws java.io.IOException
    RuntimeVisibleAnnotations: 
      org.springframework.lang.Nullable()

  protected void discardData();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
         0: .line 206
            return
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;

  protected java.lang.Object read();
    descriptor: ()Ljava/lang/Object;
    flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.read:()Lorg/springframework/core/io/buffer/DataBuffer;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.io.IOException

  private void lambda$0(io.undertow.server.HttpServerExchange, io.undertow.server.ExchangeCompletionListener$NextListener);
    descriptor: (Lio/undertow/server/HttpServerExchange;Lio/undertow/server/ExchangeCompletionListener$NextListener;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=3, args_size=3
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
        start local 1 // io.undertow.server.HttpServerExchange ex
        start local 2 // io.undertow.server.ExchangeCompletionListener$NextListener next
         0: .line 152
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.onAllDataRead:()V
         1: .line 153
            aload 2 /* next */
            invokeinterface io.undertow.server.ExchangeCompletionListener$NextListener.proceed:()V
         2: .line 154
            return
        end local 2 // io.undertow.server.ExchangeCompletionListener$NextListener next
        end local 1 // io.undertow.server.HttpServerExchange ex
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;
            0    3     1    ex  Lio/undertow/server/HttpServerExchange;
            0    3     2  next  Lio/undertow/server/ExchangeCompletionListener$NextListener;

  private void lambda$1(org.xnio.channels.StreamSourceChannel);
    descriptor: (Lorg/xnio/channels/StreamSourceChannel;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
        start local 1 // org.xnio.channels.StreamSourceChannel c
         0: .line 155
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.onDataAvailable:()V
            return
        end local 1 // org.xnio.channels.StreamSourceChannel c
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;
            0    1     1     c  Lorg/xnio/channels/StreamSourceChannel;

  private void lambda$2(org.xnio.channels.StreamSourceChannel);
    descriptor: (Lorg/xnio/channels/StreamSourceChannel;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
        start local 1 // org.xnio.channels.StreamSourceChannel c
         0: .line 156
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher.onAllDataRead:()V
            return
        end local 1 // org.xnio.channels.StreamSourceChannel c
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpRequest$RequestBodyPublisher;
            0    1     1     c  Lorg/xnio/channels/StreamSourceChannel;
}
Signature: Lorg/springframework/http/server/reactive/AbstractListenerReadPublisher<Lorg/springframework/core/io/buffer/DataBuffer;>;
SourceFile: "UndertowServerHttpRequest.java"
NestHost: org.springframework.http.server.reactive.UndertowServerHttpRequest
InnerClasses:
  public abstract NextListener = io.undertow.server.ExchangeCompletionListener$NextListener of io.undertow.server.ExchangeCompletionListener
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  private RequestBodyPublisher = org.springframework.http.server.reactive.UndertowServerHttpRequest$RequestBodyPublisher of org.springframework.http.server.reactive.UndertowServerHttpRequest
  private UndertowDataBuffer = org.springframework.http.server.reactive.UndertowServerHttpRequest$UndertowDataBuffer of org.springframework.http.server.reactive.UndertowServerHttpRequest
  public abstract Setter = org.xnio.ChannelListener$Setter of org.xnio.ChannelListener