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 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 ServletInputStream	inputStream

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

logger

Constructor Summary

Constructors

Constructor and Description
RequestBodyPublisher(ServletInputStream inputStream)

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

Constructor Detail

RequestBodyPublisher

public RequestBodyPublisher(ServletInputStream inputStream)

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