private class ServletServerHttpResponse.ResponseBodyProcessor extends AbstractListenerWriteProcessor<DataBuffer>
rsWriteLogger
Constructor and Description |
---|
ResponseBodyProcessor() |
Modifier and Type | Method and Description |
---|---|
protected void |
discardData(DataBuffer dataBuffer)
Invoked after any error (either from the upstream write Publisher, or
from I/O operations to the underlying server) and cancellation
to discard in-flight data that was in
the process of being written when the error took place.
|
protected boolean |
isDataEmpty(DataBuffer dataBuffer)
Whether the given data item has any content to write.
|
protected boolean |
isWritePossible()
Whether writing is possible.
|
protected boolean |
write(DataBuffer dataBuffer)
Write the given item.
|
protected void |
writingComplete()
Invoked after onComplete or onError notification.
|
cancel, dataReceived, getLogPrefix, onComplete, onError, onNext, onSubscribe, onWritePossible, subscribe, writingFailed, writingPaused
protected boolean isWritePossible()
AbstractListenerWriteProcessor
isWritePossible
in class AbstractListenerWriteProcessor<DataBuffer>
protected boolean isDataEmpty(DataBuffer dataBuffer)
AbstractListenerWriteProcessor
isDataEmpty
in class AbstractListenerWriteProcessor<DataBuffer>
protected boolean write(DataBuffer dataBuffer) throws java.io.IOException
AbstractListenerWriteProcessor
Note: Sub-classes are responsible for releasing any data buffer associated with the item, once fully written, if pooled buffers apply to the underlying container.
write
in class AbstractListenerWriteProcessor<DataBuffer>
dataBuffer
- the item to writetrue
), or or otherwise if more writes are required.java.io.IOException
protected void writingComplete()
AbstractListenerWriteProcessor
The default implementation is a no-op.
writingComplete
in class AbstractListenerWriteProcessor<DataBuffer>
protected void discardData(DataBuffer dataBuffer)
AbstractListenerWriteProcessor
discardData
in class AbstractListenerWriteProcessor<DataBuffer>
dataBuffer
- the data to be released