public class ReactorServerHttpRequest extends AbstractServerHttpRequest
ServerHttpRequest to the Reactor Net HttpChannel.| Constructor and Description |
|---|
ReactorServerHttpRequest(reactor.ipc.netty.http.HttpChannel 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.
|
reactor.ipc.netty.http.HttpChannel |
getReactorChannel() |
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 ReactorServerHttpRequest(reactor.ipc.netty.http.HttpChannel request,
NettyDataBufferFactory dataBufferFactory)
public reactor.ipc.netty.http.HttpChannel getReactorChannel()
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.