public class RxNettyServerHttpRequest extends AbstractServerHttpRequest
ServerHttpRequest to the RxNetty HttpServerRequest.| Constructor and Description |
|---|
RxNettyServerHttpRequest(io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> request,
NettyDataBufferFactory dataBufferFactory) |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Flux<DataBuffer> |
getBody()
Return the body of the message as a
Publisher. |
HttpMethod |
getMethod()
Return the HTTP method of the request.
|
io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> |
getRxNettyRequest() |
protected MultiValueMap<String,HttpCookie> |
initCookies()
Initialize the cookies from the underlying request.
|
protected HttpHeaders |
initHeaders()
Initialize the headers from the underlying request.
|
protected URI |
initUri()
Initialize a URI that represents the request.
|
getCookies, getHeaders, getQueryParams, getURI, initQueryParamspublic RxNettyServerHttpRequest(io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> request,
NettyDataBufferFactory dataBufferFactory)
public io.reactivex.netty.protocol.http.server.HttpServerRequest<io.netty.buffer.ByteBuf> getRxNettyRequest()
public HttpMethod getMethod()
HttpRequestnull
if not resolvable (e.g. in case of a non-standard HTTP method)protected URI initUri() throws URISyntaxException
AbstractServerHttpRequestAbstractServerHttpRequest.getURI() and then cached.initUri in class AbstractServerHttpRequestURISyntaxExceptionprotected HttpHeaders initHeaders()
AbstractServerHttpRequestAbstractServerHttpRequest.getHeaders() and then cached.initHeaders in class AbstractServerHttpRequestprotected MultiValueMap<String,HttpCookie> initCookies()
AbstractServerHttpRequestAbstractServerHttpRequest.getHeaders() and then cached.initCookies in class AbstractServerHttpRequestpublic reactor.core.publisher.Flux<DataBuffer> getBody()
ReactiveHttpInputMessagePublisher.