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

Modifier and Type	Field and Description
private ServletOutputStream	outputStream

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

currentData, logger

Constructor Summary

Constructors

Constructor and Description
ResponseBodyProcessor(ServletOutputStream outputStream)

Method Summary

Modifier and Type	Method and Description
protected boolean	isDataEmpty(DataBuffer dataBuffer) Whether the given data item contains any actual data to be processed.
protected boolean	isWritePossible() Whether writing is possible.
protected void	releaseData() Called when the current received data item can be released.
protected boolean	write(DataBuffer dataBuffer) Writes the given data to the output.

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

cancel, onComplete, onError, onNext, onSubscribe, onWritePossible, receiveData, subscribe

Methods inherited from class java.lang.Object

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

Field Detail

outputStream

private final ServletOutputStream outputStream

Constructor Detail

ResponseBodyProcessor

public ResponseBodyProcessor(ServletOutputStream outputStream)

Method Detail

isWritePossible

protected boolean isWritePossible()

Description copied from class: AbstractListenerWriteProcessor

Whether writing is possible.

Specified by:

isWritePossible in class AbstractListenerWriteProcessor<DataBuffer>

releaseData

protected void releaseData()

Description copied from class: AbstractListenerWriteProcessor

Called when the current received data item can be released.

Specified by:

releaseData in class AbstractListenerWriteProcessor<DataBuffer>

isDataEmpty

protected boolean isDataEmpty(DataBuffer dataBuffer)

Description copied from class: AbstractListenerWriteProcessor

Whether the given data item contains any actual data to be processed.

Specified by:

isDataEmpty in class AbstractListenerWriteProcessor<DataBuffer>

write

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

Description copied from class: AbstractListenerWriteProcessor

Writes the given data to the output.

Specified by:

write in class AbstractListenerWriteProcessor<DataBuffer>

Parameters:

dataBuffer - the data to write

Returns:

whether the data was fully written (true)and new data can be requested or otherwise (false)

Throws:

java.io.IOException