public class ServletServerHttpRequest extends AbstractServerHttpRequest
ServerHttpRequest
to the Servlet HttpServletRequest
.ServerHttpRequest.Builder
Constructor and Description |
---|
ServletServerHttpRequest(HttpServletRequest request,
AsyncContext asyncContext,
DataBufferFactory bufferFactory,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<DataBuffer> |
getBody()
Return the body of the message as a
Publisher . |
String |
getContextPath()
Returns the portion of the URL path that represents the context path for
the current
HttpHandler . |
HttpMethod |
getMethod()
Return the HTTP method of the request.
|
Optional<InetSocketAddress> |
getRemoteAddress()
Returns the remote address where this request is connected to.
|
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.
|
getCookies, getHeaders, getQueryParams, getURI, initQueryParams
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
mutate
protected final Log logger
public ServletServerHttpRequest(HttpServletRequest request, AsyncContext asyncContext, DataBufferFactory bufferFactory, int bufferSize) throws IOException
IOException
public HttpServletRequest getServletRequest()
public HttpMethod getMethod()
HttpRequest
null
if not resolvable (e.g. in case of a non-standard HTTP method)public String getContextPath()
ServerHttpRequest
HttpHandler
. The context path is always at the
beginning of the request path. It starts with "/" but but does not end
with "/". This method may return an empty string if no context path is
configured.protected MultiValueMap<String,HttpCookie> initCookies()
AbstractServerHttpRequest
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.
initCookies
in class AbstractServerHttpRequest
public Optional<InetSocketAddress> getRemoteAddress()
ServerHttpRequest
public reactor.core.publisher.Flux<DataBuffer> getBody()
ReactiveHttpInputMessage
Publisher
.protected DataBuffer readFromInputStream() throws IOException
ServletInputStream.isReady()
returns "true".IOException