Skip to content

Commit a8b7a5e

Browse files
TAKETODAYsdeleuze
authored andcommitted
Refine initRequestBuilder in DefaultWebClient
Closes gh-30254
1 parent 8073259 commit a8b7a5e

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -433,9 +433,7 @@ public <V> Flux<V> exchangeToFlux(Function<ClientResponse, ? extends Flux<V>> re
433433
@SuppressWarnings("deprecation")
434434
public Mono<ClientResponse> exchange() {
435435
ClientRequestObservationContext observationContext = new ClientRequestObservationContext();
436-
ClientRequest.Builder requestBuilder = this.inserter != null ?
437-
initRequestBuilder().body(this.inserter) :
438-
initRequestBuilder();
436+
ClientRequest.Builder requestBuilder = initRequestBuilder();
439437
return Mono.deferContextual(contextView -> {
440438
Observation observation = ClientHttpObservationDocumentation.HTTP_REACTIVE_CLIENT_EXCHANGES.observation(observationConvention,
441439
DEFAULT_OBSERVATION_CONVENTION, () -> observationContext, observationRegistry);
@@ -479,6 +477,9 @@ private ClientRequest.Builder initRequestBuilder() {
479477
if (this.httpRequestConsumer != null) {
480478
builder.httpRequest(this.httpRequestConsumer);
481479
}
480+
if (this.inserter != null) {
481+
builder.body(this.inserter);
482+
}
482483
return builder;
483484
}
484485

0 commit comments

Comments
 (0)