class org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor extends org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor<org.springframework.core.io.buffer.DataBuffer>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor
  super_class: org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor
{
  final org.springframework.http.server.reactive.UndertowServerHttpResponse this$0;
    descriptor: Lorg/springframework/http/server/reactive/UndertowServerHttpResponse;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  public void <init>(org.springframework.http.server.reactive.UndertowServerHttpResponse);
    descriptor: (Lorg/springframework/http/server/reactive/UndertowServerHttpResponse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 256
            aload 0 /* this */
            aload 1
            putfield org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/UndertowServerHttpResponse;
         1: .line 257
            aload 0 /* this */
            aload 1
            getfield org.springframework.http.server.reactive.UndertowServerHttpResponse.request:Lorg/springframework/http/server/reactive/UndertowServerHttpRequest;
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpRequest.getLogPrefix:()Ljava/lang/String;
            invokespecial org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor.<init>:(Ljava/lang/String;)V
         2: .line 258
            return
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyFlushProcessor;
    MethodParameters:
        Name  Flags
      this$0  final

  protected org.reactivestreams.Processor<? super org.springframework.core.io.buffer.DataBuffer, java.lang.Void> createWriteProcessor();
    descriptor: ()Lorg/reactivestreams/Processor;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 262
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/UndertowServerHttpResponse;
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpResponse.createBodyProcessor:()Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyProcessor;
            areturn
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyFlushProcessor;
    Signature: ()Lorg/reactivestreams/Processor<-Lorg/springframework/core/io/buffer/DataBuffer;Ljava/lang/Void;>;

  protected void flush();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 267
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/UndertowServerHttpResponse;
            getfield org.springframework.http.server.reactive.UndertowServerHttpResponse.responseChannel:Lorg/xnio/channels/StreamSinkChannel;
            astore 1 /* channel */
        start local 1 // org.xnio.channels.StreamSinkChannel channel
         1: .line 268
            aload 1 /* channel */
            ifnull 5
         2: .line 269
            getstatic org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.rsWriteFlushLogger:Lorg/apache/commons/logging/Log;
            invokeinterface org.apache.commons.logging.Log.isTraceEnabled:()Z
            ifeq 4
         3: .line 270
            getstatic org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.rsWriteFlushLogger:Lorg/apache/commons/logging/Log;
            new java.lang.StringBuilder
            dup
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.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 "flush"
            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
         4: .line 272
      StackMap locals: org.xnio.channels.StreamSinkChannel
      StackMap stack:
            aload 1 /* channel */
            invokeinterface org.xnio.channels.StreamSinkChannel.flush:()Z
            pop
         5: .line 274
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.xnio.channels.StreamSinkChannel channel
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0     this  Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyFlushProcessor;
            1    6     1  channel  Lorg/xnio/channels/StreamSinkChannel;
    Exceptions:
      throws java.io.IOException

  protected void flushingFailed(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
        start local 1 // java.lang.Throwable t
         0: .line 278
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.cancel:()V
         1: .line 279
            aload 0 /* this */
            aload 1 /* t */
            invokevirtual org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.onError:(Ljava/lang/Throwable;)V
         2: .line 280
            return
        end local 1 // java.lang.Throwable t
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyFlushProcessor;
            0    3     1     t  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      t     

  protected boolean isWritePossible();
    descriptor: ()Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 284
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/UndertowServerHttpResponse;
            getfield org.springframework.http.server.reactive.UndertowServerHttpResponse.responseChannel:Lorg/xnio/channels/StreamSinkChannel;
            astore 1 /* channel */
        start local 1 // org.xnio.channels.StreamSinkChannel channel
         1: .line 285
            aload 1 /* channel */
            ifnull 4
         2: .line 287
            aload 1 /* channel */
            invokeinterface org.xnio.channels.StreamSinkChannel.resumeWrites:()V
         3: .line 288
            iconst_1
            ireturn
         4: .line 290
      StackMap locals: org.xnio.channels.StreamSinkChannel
      StackMap stack:
            iconst_0
            ireturn
        end local 1 // org.xnio.channels.StreamSinkChannel channel
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyFlushProcessor;
            1    5     1  channel  Lorg/xnio/channels/StreamSinkChannel;

  protected boolean isFlushPending();
    descriptor: ()Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 295
            iconst_0
            ireturn
        end local 0 // org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/UndertowServerHttpResponse$ResponseBodyFlushProcessor;
}
Signature: Lorg/springframework/http/server/reactive/AbstractListenerWriteFlushProcessor<Lorg/springframework/core/io/buffer/DataBuffer;>;
SourceFile: "UndertowServerHttpResponse.java"
NestHost: org.springframework.http.server.reactive.UndertowServerHttpResponse
InnerClasses:
  private ResponseBodyFlushProcessor = org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyFlushProcessor of org.springframework.http.server.reactive.UndertowServerHttpResponse
  private ResponseBodyProcessor = org.springframework.http.server.reactive.UndertowServerHttpResponse$ResponseBodyProcessor of org.springframework.http.server.reactive.UndertowServerHttpResponse