@FunctionalInterface
public interface ExchangeFilterFunction
Modifier and Type | Method and Description |
---|---|
default ExchangeFilterFunction |
andThen(ExchangeFilterFunction after)
Return a composed filter function that first applies this filter, and then applies the
after filter. |
default ExchangeFunction |
apply(ExchangeFunction exchange)
Apply this filter to the given exchange function, resulting in a filtered exchange function.
|
reactor.core.publisher.Mono<ClientResponse> |
filter(ClientRequest request,
ExchangeFunction next)
Apply this filter to the given request and exchange function.
|
static ExchangeFilterFunction |
ofRequestProcessor(java.util.function.Function<ClientRequest,reactor.core.publisher.Mono<ClientRequest>> requestProcessor)
Adapt the given request processor function to a filter function that only operates on the
ClientRequest . |
static ExchangeFilterFunction |
ofResponseProcessor(java.util.function.Function<ClientResponse,reactor.core.publisher.Mono<ClientResponse>> responseProcessor)
Adapt the given response processor function to a filter function that only operates on the
ClientResponse . |
reactor.core.publisher.Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next)
The given exchange function represents the next entity in the chain, and can be invoked in order to proceed to the exchange, or not invoked to block the chain.
request
- the requestnext
- the next exchange function in the chaindefault ExchangeFilterFunction andThen(ExchangeFilterFunction after)
after
filter.after
- the filter to apply after this filter is appliedafter
functiondefault ExchangeFunction apply(ExchangeFunction exchange)
exchange
- the exchange function to filterstatic ExchangeFilterFunction ofRequestProcessor(java.util.function.Function<ClientRequest,reactor.core.publisher.Mono<ClientRequest>> requestProcessor)
ClientRequest
.requestProcessor
- the request processorstatic ExchangeFilterFunction ofResponseProcessor(java.util.function.Function<ClientResponse,reactor.core.publisher.Mono<ClientResponse>> responseProcessor)
ClientResponse
.responseProcessor
- the response processor