org.springframework.http.server.reactive

Class ServletServerHttpResponse.ResponseBodyFlushProcessor

java.lang.Object

org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor<DataBuffer>

org.springframework.http.server.reactive.ServletServerHttpResponse.ResponseBodyFlushProcessor

Enclosing class:

ServletServerHttpResponse

private class ServletServerHttpResponse.ResponseBodyFlushProcessor
extends AbstractListenerWriteFlushProcessor<DataBuffer>

Field Summary

Fields inherited from class org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor

logger

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ResponseBodyFlushProcessor()

Method Summary

Modifier and Type	Method and Description
protected <any>	createWriteProcessor() Create a new processor for subscribing to the next flush boundary.
protected void	flush() Flush the output.

Methods inherited from class org.springframework.http.server.reactive.AbstractListenerWriteFlushProcessor

cancel, onComplete, onError, onNext, onSubscribe, subscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResponseBodyFlushProcessor

private ResponseBodyFlushProcessor()

Method Detail

createWriteProcessor

protected <any> createWriteProcessor()

Description copied from class: AbstractListenerWriteFlushProcessor

Create a new processor for subscribing to the next flush boundary.

Specified by:

createWriteProcessor in class AbstractListenerWriteFlushProcessor<DataBuffer>

flush

protected void flush()
              throws java.io.IOException

Description copied from class: AbstractListenerWriteFlushProcessor

Flush the output.

Specified by:

flush in class AbstractListenerWriteFlushProcessor<DataBuffer>

Throws:

java.io.IOException