org.springframework.http.server.reactive

Class ReactorServerHttpRequest

java.lang.Object

org.springframework.http.server.reactive.AbstractServerHttpRequest

org.springframework.http.server.reactive.ReactorServerHttpRequest

All Implemented Interfaces:

HttpMessage, HttpRequest, ReactiveHttpInputMessage, ServerHttpRequest

class ReactorServerHttpRequest
extends AbstractServerHttpRequest

Adapt ServerHttpRequest to the Reactor HttpServerRequest.

Since:

5.0

Author:

Stephane Maldini, 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
private NettyDataBufferFactory	bufferFactory
private HttpServerRequest	request

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

logger

Constructor Summary

Constructors

Constructor and Description
ReactorServerHttpRequest(HttpServerRequest request, NettyDataBufferFactory bufferFactory)

Method Summary

Modifier and Type	Method and Description
<any>	getBody() Return the body of the message as a Publisher.
java.lang.String	getMethodValue() Return the HTTP method of the request as a String value.
<T> T	getNativeRequest() Return the underlying server response.
java.net.InetSocketAddress	getRemoteAddress() Return the remote address where this request is connected to, if available.
private static java.lang.String	getScheme(HttpServerRequest request)
protected MultiValueMap<java.lang.String,HttpCookie>	initCookies() Obtain the cookies from the underlying "native" request and adapt those to an HttpCookie map.
private static HttpHeaders	initHeaders(HttpServerRequest channel)
protected java.lang.String	initId() Obtain the request id to use, or null in which case the Object identity of this request instance is used.
protected SslInfo	initSslInfo() Obtain SSL session information from the underlying "native" request.
private static java.net.URI	initUri(HttpServerRequest request)
private static java.net.URI	resolveBaseUrl(HttpServerRequest request)
private static java.lang.String	resolveRequestUri(HttpServerRequest request)

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

getCookies, getHeaders, getId, getLogPrefix, getPath, getQueryParams, getSslInfo, 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

request

private final HttpServerRequest request

bufferFactory

private final NettyDataBufferFactory bufferFactory

Constructor Detail

ReactorServerHttpRequest

public ReactorServerHttpRequest(HttpServerRequest request,
                                NettyDataBufferFactory bufferFactory)
                         throws java.net.URISyntaxException

Throws:

java.net.URISyntaxException

Method Detail

initUri

private static java.net.URI initUri(HttpServerRequest request)
                             throws java.net.URISyntaxException

Throws:

java.net.URISyntaxException

resolveBaseUrl

private static java.net.URI resolveBaseUrl(HttpServerRequest request)
                                    throws java.net.URISyntaxException

Throws:

java.net.URISyntaxException

getScheme

private static java.lang.String getScheme(HttpServerRequest request)

resolveRequestUri

private static java.lang.String resolveRequestUri(HttpServerRequest request)

initHeaders

private static HttpHeaders initHeaders(HttpServerRequest channel)

getMethodValue

public java.lang.String getMethodValue()

Description copied from interface: HttpRequest

Return the HTTP method of the request as a String value.

Returns:

the HTTP method as a plain String

See Also:

HttpRequest.getMethod()

initCookies

protected MultiValueMap<java.lang.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 java.net.InetSocketAddress getRemoteAddress()

Description copied from interface: ServerHttpRequest

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

initSslInfo

@Nullable
protected SslInfo initSslInfo()

Description copied from class: AbstractServerHttpRequest

Obtain SSL session information from the underlying "native" request.

Specified by:

initSslInfo in class AbstractServerHttpRequest

Returns:

the session information, or null if none available

getBody

public <any> getBody()

Description copied from interface: ReactiveHttpInputMessage

Return the body of the message as a Publisher.

Returns:

the body content publisher

getNativeRequest

public <T> T getNativeRequest()

Description copied from class: AbstractServerHttpRequest

Return the underlying server response.

Note: This is exposed mainly for internal framework use such as WebSocket upgrades in the spring-webflux module.

Specified by:

getNativeRequest in class AbstractServerHttpRequest

initId

@Nullable
protected java.lang.String initId()

Description copied from class: AbstractServerHttpRequest

Obtain the request id to use, or null in which case the Object identity of this request instance is used.

Overrides:

initId in class AbstractServerHttpRequest