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 class UndertowServerHttpResponse.ResponseBodyProcessor
extends AbstractListenerWriteProcessor<DataBuffer>

Field Summary

Fields

Modifier and Type	Field and Description
private java.nio.ByteBuffer	byteBuffer
private StreamSinkChannel	channel
private boolean	writePossible Keep track of write listener calls, for writePossible.

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

logger

Constructor Summary

Constructors

Constructor and Description
ResponseBodyProcessor(StreamSinkChannel channel)

Method Summary

Modifier and Type	Method and Description
protected void	dataReceived(DataBuffer dataBuffer) Template method invoked after a data item to write is received via Subscriber#onNext(Object).
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.
private int	writeByteBuffer(java.nio.ByteBuffer byteBuffer)
protected void	writingComplete() Invoked after onComplete or onError notification.
protected void	writingFailed(java.lang.Throwable ex) Invoked when an I/O error occurs during a write.

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

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

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

@Nullable
private volatile java.nio.ByteBuffer byteBuffer

writePossible

private volatile boolean writePossible

Keep track of write listener calls, for writePossible.

Constructor Detail

ResponseBodyProcessor

public ResponseBodyProcessor(StreamSinkChannel channel)

Method Detail

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

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

writeByteBuffer

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

Throws:

java.io.IOException

dataReceived

protected void dataReceived(DataBuffer dataBuffer)

Description copied from class: AbstractListenerWriteProcessor

Template method invoked after a data item to write is received via Subscriber#onNext(Object). The default implementation saves the data item for writing once that is possible.

Overrides:

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

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>

writingFailed

protected void writingFailed(java.lang.Throwable ex)

Description copied from class: AbstractListenerWriteProcessor

Invoked when an I/O error occurs during a write. Sub-classes may choose to ignore this if they know the underlying API will provide an error notification in a container thread.

Defaults to no-op.

Overrides:

writingFailed in class AbstractListenerWriteProcessor<DataBuffer>