org.springframework.http.server.reactive

Class UndertowServerHttpRequest.RequestBodyPublisher

java.lang.Object

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

org.springframework.http.server.reactive.UndertowServerHttpRequest.RequestBodyPublisher

Enclosing class:

UndertowServerHttpRequest

private class UndertowServerHttpRequest.RequestBodyPublisher
extends AbstractListenerReadPublisher<DataBuffer>

Field Summary

Fields

Modifier and Type	Field and Description
private DataBufferFactory	bufferFactory
private ByteBufferPool	byteBufferPool
private StreamSourceChannel	channel

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

rsReadLogger

Constructor Summary

Constructors

Constructor and Description
RequestBodyPublisher(HttpServerExchange exchange, DataBufferFactory bufferFactory)

Method Summary

Modifier and Type	Method and Description
protected void	checkOnDataAvailable() Check if data is available and either call AbstractListenerReadPublisher.onDataAvailable() immediately or schedule a notification.
protected void	discardData() Invoked after an I/O read error from the underlying server or after a cancellation signal from the downstream consumer to allow sub-classes to discard any current cached data they might have.
protected DataBuffer	read() Read once from the input, if possible.
protected void	readingPaused() Invoked when reading is paused due to a lack of demand.
private void	registerListeners(HttpServerExchange exchange)

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

getLogPrefix, onAllDataRead, onDataAvailable, onError, subscribe

Methods inherited from class java.lang.Object

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

Field Detail

channel

private final StreamSourceChannel channel

bufferFactory

private final DataBufferFactory bufferFactory

byteBufferPool

private final ByteBufferPool byteBufferPool

Constructor Detail

RequestBodyPublisher

public RequestBodyPublisher(HttpServerExchange exchange,
                            DataBufferFactory bufferFactory)

Method Detail

registerListeners

private void registerListeners(HttpServerExchange exchange)

checkOnDataAvailable

protected void checkOnDataAvailable()

Description copied from class: AbstractListenerReadPublisher

Check if data is available and either call AbstractListenerReadPublisher.onDataAvailable() immediately or schedule a notification.

Specified by:

checkOnDataAvailable in class AbstractListenerReadPublisher<DataBuffer>

readingPaused

protected void readingPaused()

Description copied from class: AbstractListenerReadPublisher

Invoked when reading is paused due to a lack of demand.

Note: This method is guaranteed not to compete with AbstractListenerReadPublisher.checkOnDataAvailable() so it can be used to safely suspend reading, if the underlying API supports it, i.e. without competing with an implicit call to resume via checkOnDataAvailable().

Specified by:

readingPaused in class AbstractListenerReadPublisher<DataBuffer>

read

@Nullable
protected DataBuffer read()
                             throws java.io.IOException

Description copied from class: AbstractListenerReadPublisher

Read once from the input, if possible.

Specified by:

read in class AbstractListenerReadPublisher<DataBuffer>

Returns:

the item that was read; or null

Throws:

java.io.IOException

discardData

protected void discardData()

Description copied from class: AbstractListenerReadPublisher

Invoked after an I/O read error from the underlying server or after a cancellation signal from the downstream consumer to allow sub-classes to discard any current cached data they might have.

Specified by:

discardData in class AbstractListenerReadPublisher<DataBuffer>