private class ServletServerHttpResponse.ResponseBodyFlushProcessor extends AbstractListenerWriteFlushProcessor<DataBuffer>
rsWriteFlushLogger
Constructor and Description |
---|
ResponseBodyFlushProcessor() |
Modifier and Type | Method and Description |
---|---|
protected <any> |
createWriteProcessor()
Create a new processor for the current flush boundary.
|
protected void |
flush()
Flush the output if ready, or otherwise
AbstractListenerWriteFlushProcessor.isFlushPending() should
return true after. |
protected boolean |
isFlushPending()
Whether flushing is pending.
|
protected boolean |
isWritePossible()
Whether writing/flushing is possible.
|
cancel, flushingFailed, getLogPrefix, onComplete, onError, onFlushPossible, onNext, onSubscribe, subscribe
protected <any> createWriteProcessor()
AbstractListenerWriteFlushProcessor
createWriteProcessor
in class AbstractListenerWriteFlushProcessor<DataBuffer>
protected void flush() throws java.io.IOException
AbstractListenerWriteFlushProcessor
AbstractListenerWriteFlushProcessor.isFlushPending()
should
return true after.
This is primarily for the Servlet non-blocking I/O API where flush cannot be called without a readyToWrite check.
flush
in class AbstractListenerWriteFlushProcessor<DataBuffer>
java.io.IOException
protected boolean isWritePossible()
AbstractListenerWriteFlushProcessor
isWritePossible
in class AbstractListenerWriteFlushProcessor<DataBuffer>
protected boolean isFlushPending()
AbstractListenerWriteFlushProcessor
This is primarily for the Servlet non-blocking I/O API where flush cannot be called without a readyToWrite check.
isFlushPending
in class AbstractListenerWriteFlushProcessor<DataBuffer>