Class webClientAdapter

java.lang.Object

org.springframework.web.service.invoker.AbstractReactorHttpExchangeAdapter

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

All Implemented Interfaces:

HttpExchangeAdapter, ReactorHttpExchangeAdapter

public final class webClientAdapter
extends AbstractReactorHttpExchangeAdapter

ReactorHttpExchangeAdapter that enables an HttpServiceProxyFactory to use webClient for request execution.

Use static factory methods in this class to create an HttpServiceProxyFactory configured with a given webClient.

Since:

6.0

Author:

Rossen Stoyanchev

Method Summary

Modifier and Type	Method	Description
static webClientAdapter	create(webClient webClient)	Create a webClientAdapter for the given webClient instance.
reactor.core.publisher.Mono<ResponseEntity<Void>>	exchangeForBodilessEntityMono(HttpRequestValues requestValues)	Variant of ReactorHttpExchangeAdapter.exchangeForMono(HttpRequestValues) with additional access to the response status and headers.
<T> reactor.core.publisher.Flux<T>	exchangeForBodyFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Perform the given request and decode the response content to a stream with elements of the given type.
<T> reactor.core.publisher.Mono<T>	exchangeForBodyMono(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Perform the given request and decode the response content to the given type.
<T> reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>	exchangeForEntityFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Variant of ReactorHttpExchangeAdapter.exchangeForBodyFlux(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.
<T> reactor.core.publisher.Mono<ResponseEntity<T>>	exchangeForEntityMono(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Variant of ReactorHttpExchangeAdapter.exchangeForBodyMono(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.
reactor.core.publisher.Mono<HttpHeaders>	exchangeForHeadersMono(HttpRequestValues requestValues)	Perform the given request, release the response content, and return the response headers.
reactor.core.publisher.Mono<Void>	exchangeForMono(HttpRequestValues requestValues)	Perform the given request, and release the response content, if any.
boolean	supportsRequestAttributes()	Whether the underlying client supports use of request attributes.

Methods inherited from class AbstractReactorHttpExchangeAdapter

exchange, exchangeForBodilessEntity, exchangeForBody, exchangeForEntity, exchangeForHeaders, getBlockTimeout, getReactiveAdapterRegistry, setBlockTimeout, setReactiveAdapterRegistry

Methods inherited from class Object

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

Method Details

supportsRequestAttributes

public boolean supportsRequestAttributes()

Description copied from interface: HttpExchangeAdapter

Whether the underlying client supports use of request attributes.

exchangeForMono

public reactor.core.publisher.Mono<Void> exchangeForMono(HttpRequestValues requestValues)

Description copied from interface: ReactorHttpExchangeAdapter

Perform the given request, and release the response content, if any.

Parameters:

requestValues - the request to perform

Returns:

Mono that completes when the request is fully executed and the response content is released.

exchangeForHeadersMono

public reactor.core.publisher.Mono<HttpHeaders> exchangeForHeadersMono(HttpRequestValues requestValues)

Description copied from interface: ReactorHttpExchangeAdapter

Perform the given request, release the response content, and return the response headers.

Parameters:

requestValues - the request to perform

Returns:

Mono that returns the response headers the request is fully executed and the response content released.

exchangeForBodyMono

public <T> reactor.core.publisher.Mono<T> exchangeForBodyMono(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: ReactorHttpExchangeAdapter

Perform the given request and decode the response content to the given type.

Type Parameters:

T - the type the response is decoded to

Parameters:

requestValues - the request to perform

bodyType - the target type to decode to

Returns:

Mono that returns the decoded response.

exchangeForBodyFlux

public <T> reactor.core.publisher.Flux<T> exchangeForBodyFlux(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: ReactorHttpExchangeAdapter

Perform the given request and decode the response content to a stream with elements of the given type.

Type Parameters:

T - the type the response is decoded to

Parameters:

requestValues - the request to perform

bodyType - the target stream element type to decode to

Returns:

Flux with decoded stream elements.

exchangeForBodilessEntityMono

public reactor.core.publisher.Mono<ResponseEntity<Void>> exchangeForBodilessEntityMono(HttpRequestValues requestValues)

Description copied from interface: ReactorHttpExchangeAdapter

Variant of ReactorHttpExchangeAdapter.exchangeForMono(HttpRequestValues) with additional access to the response status and headers.

exchangeForEntityMono

public <T>
reactor.core.publisher.Mono<ResponseEntity<T>> exchangeForEntityMono(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: ReactorHttpExchangeAdapter

Variant of ReactorHttpExchangeAdapter.exchangeForBodyMono(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.

exchangeForEntityFlux

public <T>
reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>> exchangeForEntityFlux(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: ReactorHttpExchangeAdapter

Variant of ReactorHttpExchangeAdapter.exchangeForBodyFlux(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.

create

public static webClientAdapter create(webClient webClient)

Create a webClientAdapter for the given webClient instance.

Parameters:

webClient - the client to use

Returns:

the created adapter instance

Since:

6.1