org.springframework.http.server.reactive

Class ServletServerHttpRequest

java.lang.Object

org.springframework.http.server.reactive.AbstractServerHttpRequest

org.springframework.http.server.reactive.ServletServerHttpRequest

All Implemented Interfaces:

HttpMessage, HttpRequest, ReactiveHttpInputMessage, ServerHttpRequest

public class ServletServerHttpRequest
extends AbstractServerHttpRequest

Adapt ServerHttpRequest to the Servlet HttpServletRequest.

Since:

5.0

Author:

Rossen Stoyanchev

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.http.server.reactive.ServerHttpRequest

ServerHttpRequest.Builder

Field Summary

Fields

Modifier and Type	Field and Description
protected Log	logger

Constructor Summary

Constructors

Constructor and Description
ServletServerHttpRequest(HttpServletRequest request, AsyncContext asyncContext, DataBufferFactory bufferFactory, int bufferSize)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<DataBuffer>	getBody() Return the body of the message as a Publisher.
String	getMethodValue() Return the HTTP method of the request as a String
InetSocketAddress	getRemoteAddress() Return the remote address where this request is connected to, if available.
HttpServletRequest	getServletRequest()
protected MultiValueMap<String,HttpCookie>	initCookies() Obtain the cookies from the underlying "native" request and adapt those to an HttpCookie map.
protected DataBuffer	readFromInputStream() Read from the request body InputStream and return a DataBuffer.

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

getCookies, getHeaders, getPath, getQueryParams, getURI, initQueryParams

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.http.server.reactive.ServerHttpRequest

mutate

Methods inherited from interface org.springframework.http.HttpRequest

getMethod

Field Detail

logger

protected final Log logger

Constructor Detail

ServletServerHttpRequest

public ServletServerHttpRequest(HttpServletRequest request,
                                AsyncContext asyncContext,
                                DataBufferFactory bufferFactory,
                                int bufferSize)
                         throws IOException

Throws:

IOException

Method Detail

getServletRequest

public HttpServletRequest getServletRequest()

getMethodValue

public String getMethodValue()

Description copied from interface: HttpRequest

Return the HTTP method of the request as a String

Returns:

the HTTP method as a String

initCookies

protected MultiValueMap<String,HttpCookie> initCookies()

Description copied from class: AbstractServerHttpRequest

Obtain the cookies from the underlying "native" request and adapt those to an HttpCookie map. The return value is turned into an immutable map and cached.

Note that this method is invoked lazily on access to AbstractServerHttpRequest.getCookies(). Sub-classes should synchronize cookie initialization if the underlying "native" request does not provide thread-safe access to cookie data.

Specified by:

initCookies in class AbstractServerHttpRequest

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Description copied from interface: ServerHttpRequest

Return the remote address where this request is connected to, if available.

getBody

public reactor.core.publisher.Flux<DataBuffer> getBody()

Description copied from interface: ReactiveHttpInputMessage

Return the body of the message as a Publisher.

Returns:

the body content publisher

readFromInputStream

@Nullable
protected DataBuffer readFromInputStream()
                                            throws IOException

Read from the request body InputStream and return a DataBuffer. Invoked only when ServletInputStream.isReady() returns "true".

Throws:

IOException