class org.springframework.http.server.reactive.ServletServerHttpResponse$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.ServletServerHttpResponse$ResponseBodyFlushProcessor
  super_class: org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor
{
  final org.springframework.http.server.reactive.ServletServerHttpResponse this$0;
    descriptor: Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  public void <init>(org.springframework.http.server.reactive.ServletServerHttpResponse);
    descriptor: (Lorg/springframework/http/server/reactive/ServletServerHttpResponse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 284
            aload 0 /* this */
            aload 1
            putfield org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
         1: .line 285
            aload 0 /* this */
            aload 1
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse.request:Lorg/springframework/http/server/reactive/ServletServerHttpRequest;
            invokevirtual org.springframework.http.server.reactive.ServletServerHttpRequest.getLogPrefix:()Ljava/lang/String;
            invokespecial org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor.<init>:(Ljava/lang/String;)V
         2: .line 286
            return
        end local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/springframework/http/server/reactive/ServletServerHttpResponse$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=3, locals=2, args_size=1
        start local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 290
            new org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyProcessor
            dup
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
            invokespecial org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyProcessor.<init>:(Lorg/springframework/http/server/reactive/ServletServerHttpResponse;)V
            astore 1 /* processor */
        start local 1 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyProcessor processor
         1: .line 291
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
            aload 1 /* processor */
            putfield org.springframework.http.server.reactive.ServletServerHttpResponse.bodyProcessor:Lorg/springframework/http/server/reactive/ServletServerHttpResponse$ResponseBodyProcessor;
         2: .line 292
            aload 1 /* processor */
            areturn
        end local 1 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyProcessor processor
        end local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lorg/springframework/http/server/reactive/ServletServerHttpResponse$ResponseBodyFlushProcessor;
            1    3     1  processor  Lorg/springframework/http/server/reactive/ServletServerHttpResponse$ResponseBodyProcessor;
    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=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 297
            getstatic org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.rsWriteFlushLogger:Lorg/apache/commons/logging/Log;
            invokeinterface org.apache.commons.logging.Log.isTraceEnabled:()Z
            ifeq 2
         1: .line 298
            getstatic org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.rsWriteFlushLogger:Lorg/apache/commons/logging/Log;
            new java.lang.StringBuilder
            dup
            aload 0 /* this */
            invokevirtual org.springframework.http.server.reactive.ServletServerHttpResponse$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 attempt"
            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
         2: .line 300
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
            invokevirtual org.springframework.http.server.reactive.ServletServerHttpResponse.flush:()V
         3: .line 301
            return
        end local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/springframework/http/server/reactive/ServletServerHttpResponse$ResponseBodyFlushProcessor;
    Exceptions:
      throws java.io.IOException

  protected boolean isWritePossible();
    descriptor: ()Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 305
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
            invokevirtual org.springframework.http.server.reactive.ServletServerHttpResponse.isWritePossible:()Z
            ireturn
        end local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/ServletServerHttpResponse$ResponseBodyFlushProcessor;

  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.ServletServerHttpResponse$ResponseBodyFlushProcessor this
         0: .line 310
            aload 0 /* this */
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor.this$0:Lorg/springframework/http/server/reactive/ServletServerHttpResponse;
            getfield org.springframework.http.server.reactive.ServletServerHttpResponse.flushOnNext:Z
            ireturn
        end local 0 // org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/server/reactive/ServletServerHttpResponse$ResponseBodyFlushProcessor;
}
Signature: Lorg/springframework/http/server/reactive/AbstractListenerWriteFlushProcessor<Lorg/springframework/core/io/buffer/DataBuffer;>;
SourceFile: "ServletServerHttpResponse.java"
NestHost: org.springframework.http.server.reactive.ServletServerHttpResponse
InnerClasses:
  private ResponseBodyFlushProcessor = org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyFlushProcessor of org.springframework.http.server.reactive.ServletServerHttpResponse
  private ResponseBodyProcessor = org.springframework.http.server.reactive.ServletServerHttpResponse$ResponseBodyProcessor of org.springframework.http.server.reactive.ServletServerHttpResponse