private static class UndertowServerHttpRequest.RequestBodyPublisher extends AbstractListenerReadPublisher<DataBuffer>
Modifier and Type | Field and Description |
---|---|
private DataBufferFactory |
bufferFactory |
private ByteBufferPool |
byteBufferPool |
private StreamSourceChannel |
channel |
private PooledByteBuffer |
pooledByteBuffer |
logger
Constructor and Description |
---|
RequestBodyPublisher(HttpServerExchange exchange,
DataBufferFactory bufferFactory) |
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) |
onDataAvailable, onError, subscribe
private final StreamSourceChannel channel
private final DataBufferFactory bufferFactory
private final ByteBufferPool byteBufferPool
@Nullable private PooledByteBuffer pooledByteBuffer
public RequestBodyPublisher(HttpServerExchange exchange, DataBufferFactory bufferFactory)
private void registerListeners(HttpServerExchange exchange)
protected void checkOnDataAvailable()
checkOnDataAvailable
in class AbstractListenerReadPublisher<DataBuffer>
@Nullable protected DataBuffer read() throws java.io.IOException
AbstractListenerReadPublisher
read
in class AbstractListenerReadPublisher<DataBuffer>
null
java.io.IOException
public void onAllDataRead()
AbstractListenerReadPublisher
onAllDataRead
in class AbstractListenerReadPublisher<DataBuffer>