org.springframework.http.server.reactive

Class RxNettyServerHttpRequest

java.lang.Object

org.springframework.http.server.reactive.AbstractServerHttpRequest

org.springframework.http.server.reactive.RxNettyServerHttpRequest

All Implemented Interfaces:

HttpMessage, HttpRequest, ReactiveHttpInputMessage, ServerHttpRequest

public class RxNettyServerHttpRequest
extends AbstractServerHttpRequest

Adapt ServerHttpRequest to the RxNetty HttpServerRequest.

Since:

5.0

Author:

Rossen Stoyanchev, Stephane Maldini

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	dataBufferFactory
private java.net.InetSocketAddress	remoteAddress
private <any>	request

Constructor Summary

Constructors

Constructor and Description
RxNettyServerHttpRequest(<any> request, NettyDataBufferFactory dataBufferFactory, java.net.InetSocketAddress remoteAddress)

Method Summary

Modifier and Type	Method and Description
private static java.net.URI	getBaseUrl(java.net.InetSocketAddress address)
<any>	getBody() Return the body of the message as a Publisher.
HttpMethod	getMethod() Return the HTTP method of the request.
java.util.Optional<java.net.InetSocketAddress>	getRemoteAddress() Returns the remote address where this request is connected to.
<any>	getRxNettyRequest()
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(<any> request)
private static java.net.URI	initUri(<any> request, java.net.InetSocketAddress remoteAddress)

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

getCookies, getHeaders, 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

getContextPath, mutate

Field Detail

request

private final <any> request

dataBufferFactory

private final NettyDataBufferFactory dataBufferFactory

remoteAddress

private final java.net.InetSocketAddress remoteAddress

Constructor Detail

RxNettyServerHttpRequest

public RxNettyServerHttpRequest(<any> request,
                                NettyDataBufferFactory dataBufferFactory,
                                java.net.InetSocketAddress remoteAddress)

Method Detail

initUri

private static java.net.URI initUri(<any> request,
                                    java.net.InetSocketAddress remoteAddress)

getBaseUrl

private static java.net.URI getBaseUrl(java.net.InetSocketAddress address)

initHeaders

private static HttpHeaders initHeaders(<any> request)

getRxNettyRequest

public <any> getRxNettyRequest()

getMethod

public HttpMethod getMethod()

Description copied from interface: HttpRequest

Return the HTTP method of the request.

Returns:

the HTTP method as an HttpMethod enum value, or null if not resolvable (e.g. in case of a non-standard HTTP method)

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.util.Optional<java.net.InetSocketAddress> getRemoteAddress()

Description copied from interface: ServerHttpRequest

Returns the remote address where this request is connected to.

Returns:

remote address if available

getBody

public <any> getBody()

Description copied from interface: ReactiveHttpInputMessage

Return the body of the message as a Publisher.

Returns:

the body content publisher