Class ClientResponseWrapper

java.lang.Object

org.springframework.web.reactive.function.client.support.ClientResponseWrapper

All Implemented Interfaces:

ClientResponse

public class ClientResponseWrapper
extends Object
implements ClientResponse

Implementation of the ClientResponse interface that can be subclassed to adapt the request in a exchange filter function. All methods default to calling through to the wrapped request.

since:

5.0.5

Author:

Arjen Poutsma

Nested Class summary

Nested Classes

Modifier and Type	Class	Description
static class 	ClientResponseWrapper.HeadersWrapper	Implementation of the Headers interface that can be subclassed to adapt the headers in a exchange filter function.

Nested classes/interfaces inherited from interface ClientResponse

ClientResponse.Builder, ClientResponse.Headers

Constructor summary

Constructors

Constructor	Description
ClientResponseWrapper(ClientResponse delegate)	Create a new ClientResponseWrapper that wraps the given response.

Method summary

Modifier and Type	Method	Description
<T>&nbsp;T	body(BodyExtractor<T, ? super ClientHttpResponse>&nbsp;extractor)	Extract the body with the given BodyExtractor.
<T>&nbsp;reactor.core.publisher.Flux<T>	bodyToFlux(Class<? extends T>&nbsp;elementClass)	Extract the body to a Flux.
<T>&nbsp;reactor.core.publisher.Flux<T>	bodyToFlux(ParameterizedTypeReference<T>&nbsp;elementTypeRef)	Extract the body to a Flux.
<T>&nbsp;reactor.core.publisher.Mono<T>	bodyToMono(Class<? extends T>&nbsp;elementClass)	Extract the body to a Mono.
<T>&nbsp;reactor.core.publisher.Mono<T>	bodyToMono(ParameterizedTypeReference<T>&nbsp;elementTypeRef)	Extract the body to a Mono.
MultiValueMap<string, ResponseCookie>	cookies()	Return the cookies of this response.
<T>&nbsp;reactor.core.publisher.Mono<T>	createError()	Create a Mono that terminates with a WebClientResponseException, containing the response status, headers, body, and the originating request.
reactor.core.publisher.Mono<WebClientResponseException>	createException()	Create a WebClientResponseException that contains the response status, headers, body, and the originating request.
ClientResponse.Headers	headers()	Return the headers of this response.
string	logPrefix()	Return a log message prefix to use to correlate messages for this exchange.
reactor.core.publisher.Mono<Void>	releaseBody()	Release the body of this response.
HttpRequest	request()	Return the request associated with the response.
ClientResponse	response()	Return the wrapped request.
HttpstatusCode	statusCode()	Return the HTTP status code as an HttpstatusCode value.
Exchangestrategies	strategies()	Return the strategies used to convert the body of this response.
reactor.core.publisher.Mono<ResponseEntity<Void>>	toBodilessEntity()	Return this response as a delayed ResponseEntity containing status and headers, but no body.
<T>&nbsp;reactor.core.publisher.Mono<ResponseEntity<T>>	toEntity(Class<T>&nbsp;bodyType)	Return this response as a delayed ResponseEntity.
<T>&nbsp;reactor.core.publisher.Mono<ResponseEntity<T>>	toEntity(ParameterizedTypeReference<T>&nbsp;bodyTypeReference)	Return this response as a delayed ResponseEntity.
<T>&nbsp;reactor.core.publisher.Mono<ResponseEntity<List<T>>>	toEntityList(Class<T>&nbsp;elementClass)	Return this response as a delayed list of ResponseEntitys.
<T>&nbsp;reactor.core.publisher.Mono<ResponseEntity<List<T>>>	toEntityList(ParameterizedTypeReference<T>&nbsp;elementTypeRef)	Return this response as a delayed list of ResponseEntitys.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, tostring, wait, wait, wait

Methods inherited from interface ClientResponse

mutate

Constructor Details

ClientResponseWrapper

public ClientResponseWrapper(ClientResponse delegate)

Create a new ClientResponseWrapper that wraps the given response.

Parameters:

delegate - the response to wrap

Method Details

response

public ClientResponse response()

Return the wrapped request.

statusCode

public HttpstatusCode statusCode()

Description copied from interface: ClientResponse

Return the HTTP status code as an HttpstatusCode value.

specified by:

statusCode in interface ClientResponse

Returns:

the HTTP status as an HttpstatusCode value (never null)

headers

public ClientResponse.Headers headers()

Description copied from interface: ClientResponse

Return the headers of this response.

specified by:

headers in interface ClientResponse

cookies

public&nbsp;MultiValueMap<string, ResponseCookie>&nbsp;cookies()

Description copied from interface: ClientResponse

Return the cookies of this response.

specified by:

cookies in interface ClientResponse

strategies

public Exchangestrategies strategies()

Description copied from interface: ClientResponse

Return the strategies used to convert the body of this response.

specified by:

strategies in interface ClientResponse

request

public HttpRequest request()

Description copied from interface: ClientResponse

Return the request associated with the response.

specified by:

request in interface ClientResponse

body

public&nbsp;<T>&nbsp;T&nbsp;body(BodyExtractor<T, ? super ClientHttpResponse>&nbsp;extractor)

Description copied from interface: ClientResponse

Extract the body with the given BodyExtractor.

specified by:

body in interface ClientResponse

Type Parameters:

T - the type of the body returned

Parameters:

extractor - the BodyExtractor that reads from the response

Returns:

the extracted body

bodyToMono

public&nbsp;<T>&nbsp;reactor.core.publisher.Mono<T>&nbsp;bodyToMono(Class<? extends T>&nbsp;elementClass)

Description copied from interface: ClientResponse

Extract the body to a Mono.

specified by:

bodyToMono in interface ClientResponse

Type Parameters:

T - the element type

Parameters:

elementClass - the class of element in the Mono

Returns:

a mono containing the body of the given type T

bodyToMono

public&nbsp;<T>&nbsp;reactor.core.publisher.Mono<T>&nbsp;bodyToMono(ParameterizedTypeReference<T>&nbsp;elementTypeRef)

Description copied from interface: ClientResponse

Extract the body to a Mono.

specified by:

bodyToMono in interface ClientResponse

Type Parameters:

T - the element type

Parameters:

elementTypeRef - the type reference of element in the Mono

Returns:

a mono containing the body of the given type T

bodyToFlux

public&nbsp;<T>&nbsp;reactor.core.publisher.Flux<T>&nbsp;bodyToFlux(Class<? extends T>&nbsp;elementClass)

Description copied from interface: ClientResponse

Extract the body to a Flux.

specified by:

bodyToFlux in interface ClientResponse

Type Parameters:

T - the element type

Parameters:

elementClass - the class of elements in the Flux

Returns:

a flux containing the body of the given type T

bodyToFlux

public&nbsp;<T>&nbsp;reactor.core.publisher.Flux<T>&nbsp;bodyToFlux(ParameterizedTypeReference<T>&nbsp;elementTypeRef)

Description copied from interface: ClientResponse

Extract the body to a Flux.

specified by:

bodyToFlux in interface ClientResponse

Type Parameters:

T - the element type

Parameters:

elementTypeRef - the type reference of elements in the Flux

Returns:

a flux containing the body of the given type T

releaseBody

public&nbsp;reactor.core.publisher.Mono<Void>&nbsp;releaseBody()

Description copied from interface: ClientResponse

Release the body of this response.

specified by:

releaseBody in interface ClientResponse

Returns:

a completion signal

see Also:

• DataBufferUtils.release(DataBuffer)

toBodilessEntity

public&nbsp;reactor.core.publisher.Mono<ResponseEntity<Void>>&nbsp;toBodilessEntity()

Description copied from interface: ClientResponse

Return this response as a delayed ResponseEntity containing status and headers, but no body. Calling this method will release the body of the response.

specified by:

toBodilessEntity in interface ClientResponse

Returns:

Mono with the bodiless ResponseEntity

toEntity

public&nbsp;<T>
reactor.core.publisher.Mono<ResponseEntity<T>>&nbsp;toEntity(Class<T>&nbsp;bodyType)

Description copied from interface: ClientResponse

Return this response as a delayed ResponseEntity.

specified by:

toEntity in interface ClientResponse

Type Parameters:

T - response body type

Parameters:

bodyType - the expected response body type

Returns:

Mono with the ResponseEntity

toEntity

public&nbsp;<T>
reactor.core.publisher.Mono<ResponseEntity<T>>&nbsp;toEntity(ParameterizedTypeReference<T>&nbsp;bodyTypeReference)

Description copied from interface: ClientResponse

Return this response as a delayed ResponseEntity.

specified by:

toEntity in interface ClientResponse

Type Parameters:

T - response body type

Parameters:

bodyTypeReference - a type reference describing the expected response body type

Returns:

Mono with the ResponseEntity

toEntityList

public&nbsp;<T>
reactor.core.publisher.Mono<ResponseEntity<List<T>>>&nbsp;toEntityList(Class<T>&nbsp;elementClass)

Description copied from interface: ClientResponse

Return this response as a delayed list of ResponseEntitys.

specified by:

toEntityList in interface ClientResponse

Type Parameters:

T - the type of elements in the list

Parameters:

elementClass - the expected response body list element class

Returns:

Mono with the list of ResponseEntitys

toEntityList

public&nbsp;<T>
reactor.core.publisher.Mono<ResponseEntity<List<T>>>&nbsp;toEntityList(ParameterizedTypeReference<T>&nbsp;elementTypeRef)

Description copied from interface: ClientResponse

Return this response as a delayed list of ResponseEntitys.

specified by:

toEntityList in interface ClientResponse

Type Parameters:

T - the type of elements in the list

Parameters:

elementTypeRef - the expected response body list element reference type

Returns:

Mono with the list of ResponseEntitys

createException

public&nbsp;reactor.core.publisher.Mono<WebClientResponseException>&nbsp;createException()

Description copied from interface: ClientResponse

Create a WebClientResponseException that contains the response status, headers, body, and the originating request.

specified by:

createException in interface ClientResponse

Returns:

a Mono with the created exception

createError

public&nbsp;<T>&nbsp;reactor.core.publisher.Mono<T>&nbsp;createError()

Description copied from interface: ClientResponse

Create a Mono that terminates with a WebClientResponseException, containing the response status, headers, body, and the originating request.

specified by:

createError in interface ClientResponse

Type Parameters:

T - the reified type

Returns:

a Mono that fails with a WebClientResponseException.

see Also:

• ClientResponse.createException()

logPrefix

public string logPrefix()

Description copied from interface: ClientResponse

Return a log message prefix to use to correlate messages for this exchange.

The prefix is based on ClientRequest.logPrefix(), which itself is based on the value of the LOG_ID_ATTRIBUTE request attribute, further surrounded with "[" and "]".

specified by:

logPrefix in interface ClientResponse

Returns:

the log message prefix or an empty string if the LOG_ID_ATTRIBUTE is not set