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 static class UndertowServerHttpRequest.RequestBodyPublisher
extends AbstractListenerReadPublisher<DataBuffer>

Field Summary

Fields

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

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

logger

Constructor Summary

Constructors

Constructor and Description
RequestBodyPublisher(HttpServerExchange exchange, DataBufferFactory bufferFactory)

Method Summary

Modifier and Type	Method and Description
protected void	checkOnDataAvailable()
void	onAllDataRead() Listeners can call this to notify when all data has been read.
protected DataBuffer	read() Reads a data from the input, if possible.
private void	registerListeners(HttpServerExchange exchange)

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

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

pooledByteBuffer

private PooledByteBuffer pooledByteBuffer

Constructor Detail

RequestBodyPublisher

public RequestBodyPublisher(HttpServerExchange exchange,
                            DataBufferFactory bufferFactory)

Method Detail

registerListeners

private void registerListeners(HttpServerExchange exchange)

checkOnDataAvailable

protected void checkOnDataAvailable()

Specified by:

checkOnDataAvailable in class AbstractListenerReadPublisher<DataBuffer>

read

protected DataBuffer read()
                   throws java.io.IOException

Description copied from class: AbstractListenerReadPublisher

Reads a data from the input, if possible.

Specified by:

read in class AbstractListenerReadPublisher<DataBuffer>

Returns:

the data that was read; or null

Throws:

java.io.IOException

onAllDataRead

public void onAllDataRead()

Description copied from class: AbstractListenerReadPublisher

Listeners can call this to notify when all data has been read.

Overrides:

onAllDataRead in class AbstractListenerReadPublisher<DataBuffer>