Class ReactorHttpExchangeAdapterDecorator

java.lang.Object

org.springframework.web.service.invoker.HttpExchangeAdapterDecorator

org.springframework.web.service.invoker.ReactorHttpExchangeAdapterDecorator

All Implemented Interfaces:

HttpExchangeAdapter, ReactorHttpExchangeAdapter

Direct Known Subclasses:

NotFoundWebClientAdapterDecorator

public class ReactorHttpExchangeAdapterDecorator
extends HttpExchangeAdapterDecorator
implements ReactorHttpExchangeAdapter

ReactorHttpExchangeAdapter that wraps and delegates to another adapter instance.

Since:

7.0

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor	Description
ReactorHttpExchangeAdapterDecorator(HttpExchangeAdapter delegate)

Method Summary

Modifier and Type	Method	Description
void	exchange(HttpRequestValues requestValues)	Perform the given request, and release the response content, if any.
ResponseEntity<Void>	exchangeForBodilessEntity(HttpRequestValues requestValues)	Variant of HttpExchangeAdapter.exchange(HttpRequestValues) with additional access to the response status and headers.
reactor.core.publisher.Mono<ResponseEntity<Void>>	exchangeForBodilessEntityMono(HttpRequestValues values)	Variant of ReactorHttpExchangeAdapter.exchangeForMono(HttpRequestValues) with additional access to the response status and headers.
<T> @Nullable T	exchangeForBody(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Perform the given request and decode the response content to the given type.
<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> ResponseEntity<T>	exchangeForEntity(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType)	Variant of HttpExchangeAdapter.exchangeForBody(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.
<T> reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>	exchangeForEntityFlux(HttpRequestValues values, 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 values, ParameterizedTypeReference<T> bodyType)	Variant of ReactorHttpExchangeAdapter.exchangeForBodyMono(HttpRequestValues, ParameterizedTypeReference) with additional access to the response status and headers.
HttpHeaders	exchangeForHeaders(HttpRequestValues requestValues)	Perform the given request, release the response content, and return the response 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.
@Nullable Duration	getBlockTimeout()	Return the configured time to block for the response from an HTTP service method with a synchronous (blocking) method signature.
ReactorHttpExchangeAdapter	getHttpExchangeAdapter()	Return the wrapped delegate HttpExchangeAdapter.
ReactiveAdapterRegistry	getReactiveAdapterRegistry()	Return the configured ReactiveAdapterRegistry.
boolean	supportsRequestAttributes()	Whether the underlying client supports use of request attributes.

Methods inherited from class Object

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

Constructor Details

ReactorHttpExchangeAdapterDecorator

public ReactorHttpExchangeAdapterDecorator(HttpExchangeAdapter delegate)

Method Details

getHttpExchangeAdapter

public ReactorHttpExchangeAdapter getHttpExchangeAdapter()

Return the wrapped delegate HttpExchangeAdapter.

Overrides:

getHttpExchangeAdapter in class HttpExchangeAdapterDecorator

supportsRequestAttributes

public boolean supportsRequestAttributes()

Description copied from interface: HttpExchangeAdapter

Whether the underlying client supports use of request attributes.

Specified by:

supportsRequestAttributes in interface HttpExchangeAdapter

Overrides:

supportsRequestAttributes in class HttpExchangeAdapterDecorator

exchange

public void exchange(HttpRequestValues requestValues)

Description copied from interface: HttpExchangeAdapter

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

Specified by:

exchange in interface HttpExchangeAdapter

Overrides:

exchange in class HttpExchangeAdapterDecorator

Parameters:

requestValues - the request to perform

exchangeForHeaders

public HttpHeaders exchangeForHeaders(HttpRequestValues requestValues)

Description copied from interface: HttpExchangeAdapter

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

Specified by:

exchangeForHeaders in interface HttpExchangeAdapter

Overrides:

exchangeForHeaders in class HttpExchangeAdapterDecorator

Parameters:

requestValues - the request to perform

Returns:

the response headers

exchangeForBody

public <T> @Nullable T exchangeForBody(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: HttpExchangeAdapter

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

Specified by:

exchangeForBody in interface HttpExchangeAdapter

Overrides:

exchangeForBody in class HttpExchangeAdapterDecorator

Type Parameters:

T - the type the response is decoded to

Parameters:

requestValues - the request to perform

bodyType - the target type to decode to

Returns:

the decoded response body.

exchangeForBodilessEntity

public ResponseEntity<Void> exchangeForBodilessEntity(HttpRequestValues requestValues)

Description copied from interface: HttpExchangeAdapter

Variant of HttpExchangeAdapter.exchange(HttpRequestValues) with additional access to the response status and headers.

Specified by:

exchangeForBodilessEntity in interface HttpExchangeAdapter

Overrides:

exchangeForBodilessEntity in class HttpExchangeAdapterDecorator

Returns:

the response entity with status and headers.

exchangeForEntity

public <T> ResponseEntity<T> exchangeForEntity(HttpRequestValues requestValues,
 ParameterizedTypeReference<T> bodyType)

Description copied from interface: HttpExchangeAdapter

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

Specified by:

exchangeForEntity in interface HttpExchangeAdapter

Overrides:

exchangeForEntity in class HttpExchangeAdapterDecorator

Returns:

the response entity with status, headers, and body.

getReactiveAdapterRegistry

public ReactiveAdapterRegistry getReactiveAdapterRegistry()

Description copied from interface: ReactorHttpExchangeAdapter

Return the configured ReactiveAdapterRegistry.

Specified by:

getReactiveAdapterRegistry in interface ReactorHttpExchangeAdapter

getBlockTimeout

public @Nullable Duration getBlockTimeout()

Description copied from interface: ReactorHttpExchangeAdapter

Return the configured time to block for the response from an HTTP service method with a synchronous (blocking) method signature.

By default, not set in which case the behavior depends on connection and request timeout settings of the underlying HTTP client. We recommend configuring timeout values directly on the underlying HTTP client, which provides more control over such settings.

Specified by:

getBlockTimeout in interface ReactorHttpExchangeAdapter

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.

Specified by:

exchangeForMono in interface ReactorHttpExchangeAdapter

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.

Specified by:

exchangeForHeadersMono in interface ReactorHttpExchangeAdapter

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.

Specified by:

exchangeForBodyMono in interface ReactorHttpExchangeAdapter

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.

Specified by:

exchangeForBodyFlux in interface ReactorHttpExchangeAdapter

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 values)

Description copied from interface: ReactorHttpExchangeAdapter

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

Specified by:

exchangeForBodilessEntityMono in interface ReactorHttpExchangeAdapter

exchangeForEntityMono

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

Description copied from interface: ReactorHttpExchangeAdapter

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

Specified by:

exchangeForEntityMono in interface ReactorHttpExchangeAdapter

exchangeForEntityFlux

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

Description copied from interface: ReactorHttpExchangeAdapter

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

Specified by:

exchangeForEntityFlux in interface ReactorHttpExchangeAdapter