org.springframework.http.server.reactive

Class UndertowServerHttpResponse.ResponseBodyFlushProcessor

java.lang.Object

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

org.springframework.http.server.reactive.UndertowServerHttpResponse.ResponseBodyFlushProcessor

Enclosing class:

UndertowServerHttpResponse

private class UndertowServerHttpResponse.ResponseBodyFlushProcessor
extends AbstractListenerWriteFlushProcessor<DataBuffer>

Field Summary

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

rsWriteFlushLogger

Constructor Summary

Constructors

Constructor and Description
ResponseBodyFlushProcessor()

Method Summary

Modifier and Type	Method and Description
protected <any>	createWriteProcessor() Create a new processor for the current flush boundary.
protected void	flush() Flush the output if ready, or otherwise AbstractListenerWriteFlushProcessor.isFlushPending() should return true after.
protected void	flushingFailed(java.lang.Throwable t) Invoked when an error happens while flushing.
protected boolean	isFlushPending() Whether flushing is pending.
protected boolean	isWritePossible() Whether writing/flushing is possible.

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

cancel, getLogPrefix, onComplete, onError, onFlushPossible, onNext, onSubscribe, subscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseBodyFlushProcessor

public ResponseBodyFlushProcessor()

Method Detail

createWriteProcessor

protected <any> createWriteProcessor()

Description copied from class: AbstractListenerWriteFlushProcessor

Create a new processor for the current flush boundary.

Specified by:

createWriteProcessor in class AbstractListenerWriteFlushProcessor<DataBuffer>

flush

protected void flush()
              throws java.io.IOException

Description copied from class: AbstractListenerWriteFlushProcessor

Flush the output if ready, or otherwise AbstractListenerWriteFlushProcessor.isFlushPending() should return true after.

This is primarily for the Servlet non-blocking I/O API where flush cannot be called without a readyToWrite check.

Specified by:

flush in class AbstractListenerWriteFlushProcessor<DataBuffer>

Throws:

java.io.IOException

flushingFailed

protected void flushingFailed(java.lang.Throwable t)

Description copied from class: AbstractListenerWriteFlushProcessor

Invoked when an error happens while flushing. 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:

flushingFailed in class AbstractListenerWriteFlushProcessor<DataBuffer>

isWritePossible

protected boolean isWritePossible()

Description copied from class: AbstractListenerWriteFlushProcessor

Whether writing/flushing is possible.

Specified by:

isWritePossible in class AbstractListenerWriteFlushProcessor<DataBuffer>

isFlushPending

protected boolean isFlushPending()

Description copied from class: AbstractListenerWriteFlushProcessor

Whether flushing is pending.

This is primarily for the Servlet non-blocking I/O API where flush cannot be called without a readyToWrite check.

Specified by:

isFlushPending in class AbstractListenerWriteFlushProcessor<DataBuffer>