org.springframework.http.server.reactive

Class UndertowServerHttpResponse.ResponseBodyProcessor

java.lang.Object

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

org.springframework.http.server.reactive.UndertowServerHttpResponse.ResponseBodyProcessor

Enclosing class:

UndertowServerHttpResponse

private static class UndertowServerHttpResponse.ResponseBodyProcessor
extends AbstractListenerWriteProcessor<DataBuffer>

Field Summary

Fields

Modifier and Type	Field and Description
private java.nio.ByteBuffer	byteBuffer
private StreamSinkChannel	channel

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

currentData, logger

Constructor Summary

Constructors

Constructor and Description
ResponseBodyProcessor(StreamSinkChannel channel)

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	receiveData(DataBuffer dataBuffer) Called when a data item is received via Subscriber#onNext(Object)
void	registerListener()
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.
private int	writeByteBuffer(java.nio.ByteBuffer byteBuffer)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

channel

private final StreamSinkChannel channel

byteBuffer

private volatile java.nio.ByteBuffer byteBuffer

Constructor Detail

ResponseBodyProcessor

public ResponseBodyProcessor(StreamSinkChannel channel)

Method Detail

registerListener

public void registerListener()

isWritePossible

protected boolean isWritePossible()

Description copied from class: AbstractListenerWriteProcessor

Whether writing is possible.

Specified by:

isWritePossible 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

writeByteBuffer

private int writeByteBuffer(java.nio.ByteBuffer byteBuffer)
                     throws java.io.IOException

Throws:

java.io.IOException

receiveData

protected void receiveData(DataBuffer dataBuffer)

Description copied from class: AbstractListenerWriteProcessor

Called when a data item is received via Subscriber#onNext(Object)

Overrides:

receiveData 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>