org.springframework.web.reactive.function.client

Interface WebClient.RequestHeadersSpec<S extends WebClient.RequestHeadersSpec<S>>

All Known Subinterfaces:

WebClient.RequestBodySpec, WebClient.RequestBodyUriSpec, WebClient.RequestHeadersUriSpec<S>

Enclosing interface:

WebClient

public static interface WebClient.RequestHeadersSpec<S extends WebClient.RequestHeadersSpec<S>>

Contract for specifying request headers leading up to the exchange.

Method Summary

Modifier and Type	Method and Description
S	accept(MediaType... acceptableMediaTypes) Set the list of acceptable media types, as specified by the Accept header.
S	acceptCharset(Charset... acceptableCharsets) Set the list of acceptable charsets, as specified by the Accept-Charset header.
S	attribute(String name, Object value) Set the attribute with the given name to the given value.
S	attributes(Consumer<Map<String,Object>> attributesConsumer) Manipulate the request attributes with the given consumer.
S	cookie(String name, String value) Add a cookie with the given name and value.
S	cookies(Consumer<MultiValueMap<String,String>> cookiesConsumer) Manipulate the request's cookies with the given consumer.
reactor.core.publisher.Mono<ClientResponse>	exchange() Exchange the request for a ClientResponse with full access to the response status and headers before extracting the body.
S	header(String headerName, String... headerValues) Add the given, single header value under the given name.
S	headers(Consumer<HttpHeaders> headersConsumer) Manipulate the request's headers with the given consumer.
S	ifModifiedSince(ZonedDateTime ifModifiedSince) Set the value of the If-Modified-Since header.
S	ifNoneMatch(String... ifNoneMatches) Set the values of the If-None-Match header.
WebClient.ResponseSpec	retrieve() A variant of exchange() that provides the shortest path to retrieving the full response (i.e.

Method Detail

accept

S accept(MediaType... acceptableMediaTypes)

Set the list of acceptable media types, as specified by the Accept header.

Parameters:

acceptableMediaTypes - the acceptable media types

Returns:

this builder

acceptCharset

S acceptCharset(Charset... acceptableCharsets)

Set the list of acceptable charsets, as specified by the Accept-Charset header.

Parameters:

acceptableCharsets - the acceptable charsets

Returns:

this builder

cookie

S cookie(String name,
         String value)

Add a cookie with the given name and value.

Parameters:

name - the cookie name

value - the cookie value

Returns:

this builder

cookies

S cookies(Consumer<MultiValueMap<String,String>> cookiesConsumer)

Manipulate the request's cookies with the given consumer. The map provided to the consumer is "live", so that the consumer can be used to overwrite existing header values, remove values, or use any of the other MultiValueMap methods.

Parameters:

cookiesConsumer - a function that consumes the cookies map

Returns:

this builder

ifModifiedSince

S ifModifiedSince(ZonedDateTime ifModifiedSince)

Set the value of the If-Modified-Since header.

The date should be specified as the number of milliseconds since January 1, 1970 GMT.

Parameters:

ifModifiedSince - the new value of the header

Returns:

this builder

ifNoneMatch

S ifNoneMatch(String... ifNoneMatches)

Set the values of the If-None-Match header.

Parameters:

ifNoneMatches - the new value of the header

Returns:

this builder

header

S header(String headerName,
         String... headerValues)

Add the given, single header value under the given name.

Parameters:

headerName - the header name

headerValues - the header value(s)

Returns:

this builder

headers

S headers(Consumer<HttpHeaders> headersConsumer)

Manipulate the request's headers with the given consumer. The headers provided to the consumer are "live", so that the consumer can be used to overwrite existing header values, remove values, or use any of the other HttpHeaders methods.

Parameters:

headersConsumer - a function that consumes the HttpHeaders

Returns:

this builder

attribute

S attribute(String name,
            Object value)

Set the attribute with the given name to the given value.

Parameters:

name - the name of the attribute to add

value - the value of the attribute to add

Returns:

this builder

attributes

S attributes(Consumer<Map<String,Object>> attributesConsumer)

Manipulate the request attributes with the given consumer. The attributes provided to the consumer are "live", so that the consumer can be used to inspect attributes, remove attributes, or use any of the other map-provided methods.

Parameters:

attributesConsumer - a function that consumes the attributes

Returns:

this builder

exchange

reactor.core.publisher.Mono<ClientResponse> exchange()

Exchange the request for a ClientResponse with full access to the response status and headers before extracting the body.

Use Mono.flatMap(Function) or Mono.flatMapMany(Function) to compose further on the response:

 Mono<Pojo> mono = client.get().uri("/")
     .accept(MediaType.APPLICATION_JSON)
     .exchange()
     .flatMap(response -> response.bodyToMono(Pojo.class));

 Flux<Pojo> flux = client.get().uri("/")
     .accept(MediaType.APPLICATION_STREAM_JSON)
     .exchange()
     .flatMapMany(response -> response.bodyToFlux(Pojo.class));
 

The response body should always be consumed with bodyTo* or toEntity* methods; if you do not care about the body, you can use bodyToMono(Void.class).

Not consuming the response body might lead to HTTP connection pool inconsistencies or memory leaks.

Returns:

a Mono with the response

See Also:

retrieve()

retrieve

WebClient.ResponseSpec retrieve()

A variant of exchange() that provides the shortest path to retrieving the full response (i.e. status, headers, and body) where instead of returning Mono<ClientResponse> it exposes shortcut methods to extract the response body.

Use of this method is simpler when you don't need to deal directly with ClientResponse, e.g. to use a custom BodyExtractor or to check the status and headers before extracting the response.

 Mono<Pojo> bodyMono = client.get().uri("/")
     .accept(MediaType.APPLICATION_JSON)
     .retrieve()
     .bodyToMono(Pojo.class);
 

Returns:

spec with options for extracting the response body