Package | Description |
---|---|
org.springframework.web.reactive.function.client |
Provides a reactive
WebClient
that builds on top of the
org.springframework.http.client.reactive reactive HTTP adapter layer. |
org.springframework.web.reactive.function.client.support |
Classes supporting the
org.springframework.web.reactive.function.client package. |
Modifier and Type | Method and Description |
---|---|
ClientResponse |
ClientResponse.Builder.build()
Build the response.
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<ClientResponse> |
WebClient.RequestHeadersSpec.exchange()
Deprecated.
since 5.3 due to the possibility to leak memory and/or
connections; please, use
WebClient.RequestHeadersSpec.exchangeToMono(Function) ,
WebClient.RequestHeadersSpec.exchangeToFlux(Function) ; consider also using
WebClient.RequestHeadersSpec.retrieve() which provides access to the response status
and headers via ResponseEntity along with error status
handling. |
reactor.core.publisher.Mono<ClientResponse> |
ExchangeFunction.exchange(ClientRequest request)
Exchange the given request for a response mono.
|
reactor.core.publisher.Mono<ClientResponse> |
ExchangeFilterFunction.filter(ClientRequest request,
ExchangeFunction next)
Apply this filter to the given request and exchange function.
|
Modifier and Type | Method and Description |
---|---|
static ClientResponse.Builder |
ClientResponse.from(ClientResponse other)
Deprecated.
as of 5.3 in favor of the instance based
mutate() . |
Modifier and Type | Method and Description |
---|---|
<V> reactor.core.publisher.Flux<V> |
WebClient.RequestHeadersSpec.exchangeToFlux(Function<ClientResponse,? extends reactor.core.publisher.Flux<V>> responseHandler)
An alternative to
WebClient.RequestHeadersSpec.retrieve() that provides more control via
access to the ClientResponse . |
<V> reactor.core.publisher.Mono<V> |
WebClient.RequestHeadersSpec.exchangeToMono(Function<ClientResponse,? extends reactor.core.publisher.Mono<V>> responseHandler)
An alternative to
WebClient.RequestHeadersSpec.retrieve() that provides more control via
access to the ClientResponse . |
static ExchangeFilterFunction |
ExchangeFilterFunction.ofResponseProcessor(Function<ClientResponse,reactor.core.publisher.Mono<ClientResponse>> processor)
Adapt the given response processor function to a filter function that
only operates on the
ClientResponse . |
static ExchangeFilterFunction |
ExchangeFilterFunction.ofResponseProcessor(Function<ClientResponse,reactor.core.publisher.Mono<ClientResponse>> processor)
Adapt the given response processor function to a filter function that
only operates on the
ClientResponse . |
WebClient.ResponseSpec |
WebClient.ResponseSpec.onRawStatus(IntPredicate statusCodePredicate,
Function<ClientResponse,reactor.core.publisher.Mono<? extends Throwable>> exceptionFunction)
Variant of
WebClient.ResponseSpec.onStatus(Predicate, Function) that works with
raw status code values. |
WebClient.ResponseSpec |
WebClient.ResponseSpec.onStatus(Predicate<HttpStatus> statusPredicate,
Function<ClientResponse,reactor.core.publisher.Mono<? extends Throwable>> exceptionFunction)
Provide a function to map specific error status codes to an error
signal to be propagated downstream instead of the response.
|
static ExchangeFilterFunction |
ExchangeFilterFunctions.statusError(Predicate<HttpStatus> statusPredicate,
Function<ClientResponse,? extends Throwable> exceptionFunction)
Return a filter that generates an error signal when the given
HttpStatus predicate matches. |
Modifier and Type | Class and Description |
---|---|
class |
ClientResponseWrapper
Implementation of the
ClientResponse interface that can be subclassed
to adapt the request in a
exchange filter function . |
Modifier and Type | Method and Description |
---|---|
ClientResponse |
ClientResponseWrapper.response()
Return the wrapped request.
|
Constructor and Description |
---|
ClientResponseWrapper(ClientResponse delegate)
Create a new
ClientResponseWrapper that wraps the given response. |