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

rsReadLogger

Constructor Summary

Constructors

Constructor and Description
RequestBodyPublisher(ServletInputStream inputStream)

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.
void	registerReadListener()

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

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()

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>

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

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>

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>