org.springframework.http.server.reactive

Class ServletServerHttpResponse.ResponseBodyProcessor

java.lang.Object

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

org.springframework.http.server.reactive.ServletServerHttpResponse.ResponseBodyProcessor

Enclosing class:

ServletServerHttpResponse

private class ServletServerHttpResponse.ResponseBodyProcessor
extends AbstractListenerWriteProcessor<DataBuffer>

Field Summary

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

logger

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ResponseBodyProcessor()

Method Summary

Modifier and Type	Method and Description
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.

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

cancel, dataReceived, onComplete, onError, onNext, onSubscribe, onWritePossible, subscribe, writingFailed, writingPaused

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseBodyProcessor

private ResponseBodyProcessor()

Method Detail

isWritePossible

protected boolean isWritePossible()

Description copied from class: AbstractListenerWriteProcessor

Whether writing is possible.

Specified by:

isWritePossible in class AbstractListenerWriteProcessor<DataBuffer>

isDataEmpty

protected boolean isDataEmpty(DataBuffer dataBuffer)

Description copied from class: AbstractListenerWriteProcessor

Whether the given data item has any content to write. If false the item is not written.

Specified by:

isDataEmpty in class AbstractListenerWriteProcessor<DataBuffer>

write

protected boolean write(DataBuffer dataBuffer)
                 throws java.io.IOException

Description copied from class: AbstractListenerWriteProcessor

Write the given item.

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.

Specified by:

write in class AbstractListenerWriteProcessor<DataBuffer>

Parameters:

dataBuffer - the item to write

Returns:

whether the current data item was written and another one requested (true), or or otherwise if more writes are required.

Throws:

java.io.IOException

writingComplete

protected void writingComplete()

Description copied from class: AbstractListenerWriteProcessor

Invoked after onComplete or onError notification.

The default implementation is a no-op.

Overrides:

writingComplete in class AbstractListenerWriteProcessor<DataBuffer>