org.springframework.http.server.reactive

Class ServletServerHttpRequest.RequestBodyPublisher

java.lang.Object

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

org.springframework.http.server.reactive.ServletServerHttpRequest.RequestBodyPublisher

Enclosing class:

ServletServerHttpRequest

private static class ServletServerHttpRequest.RequestBodyPublisher
extends AbstractListenerReadPublisher<DataBuffer>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ServletServerHttpRequest.RequestBodyPublisher.RequestBodyPublisherReadListener

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	buffer
private DataBufferFactory	bufferFactory
private ServletInputStream	inputStream

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

logger

Constructor Summary

Constructors

Constructor and Description
RequestBodyPublisher(ServletInputStream inputStream, DataBufferFactory bufferFactory, int bufferSize)

Method Summary

Modifier and Type	Method and Description
protected void	checkOnDataAvailable()
protected DataBuffer	read() Reads a data from the input, if possible.
void	registerReadListener()

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

onAllDataRead, onDataAvailable, onError, subscribe

Methods inherited from class java.lang.Object

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

Field Detail

inputStream

private final ServletInputStream inputStream

bufferFactory

private final DataBufferFactory bufferFactory

buffer

private final byte[] buffer

Constructor Detail

RequestBodyPublisher

public RequestBodyPublisher(ServletInputStream inputStream,
                            DataBufferFactory bufferFactory,
                            int bufferSize)

Method Detail

registerReadListener

public void registerReadListener()
                          throws java.io.IOException

Throws:

java.io.IOException

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