public class ReactorClientHttpResponse extends Object implements ClientHttpResponse
ClientHttpResponse implementation for the Reactor-Netty HTTP client.HttpClient| Constructor and Description |
|---|
ReactorClientHttpResponse(reactor.ipc.netty.http.client.HttpClientResponse response) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close this response, freeing any resources created.
|
reactor.core.publisher.Flux<DataBuffer> |
getBody()
Return the body of the message as a
Publisher. |
MultiValueMap<String,ResponseCookie> |
getCookies()
Return a read-only map of response cookies received from the server.
|
HttpHeaders |
getHeaders()
Return the headers of this message.
|
HttpStatus |
getStatusCode()
Return the HTTP status as an
HttpStatus enum value. |
String |
toString() |
public ReactorClientHttpResponse(reactor.ipc.netty.http.client.HttpClientResponse response)
public reactor.core.publisher.Flux<DataBuffer> getBody()
ReactiveHttpInputMessagePublisher.getBody in interface ReactiveHttpInputMessagepublic HttpHeaders getHeaders()
HttpMessagegetHeaders in interface HttpMessagenull)public HttpStatus getStatusCode()
ClientHttpResponseHttpStatus enum value.getStatusCode in interface ClientHttpResponsepublic MultiValueMap<String,ResponseCookie> getCookies()
ClientHttpResponsegetCookies in interface ClientHttpResponsepublic void close()
ClientHttpResponseThis non-blocking method has to be called once the response has been processed and the resources are no longer needed; not doing so might create resource leaks or connection issues.
Depending on the client configuration and HTTP version, this can lead to closing the connection or returning it to a connection pool.
close in interface Closeableclose in interface AutoCloseableclose in interface ClientHttpResponse