|
|
|
@ -79,7 +79,9 @@ final class DefaultWebClient implements WebClient {
@@ -79,7 +79,9 @@ final class DefaultWebClient implements WebClient {
|
|
|
|
|
private static final Mono<ClientResponse> NO_HTTP_CLIENT_RESPONSE_ERROR = Mono.error( |
|
|
|
|
() -> new IllegalStateException("The underlying HTTP client completed without emitting a response.")); |
|
|
|
|
|
|
|
|
|
private static final DefaultClientRequestObservationConvention DEFAULT_OBSERVATION_CONVENTION = new DefaultClientRequestObservationConvention(); |
|
|
|
|
private static final DefaultClientRequestObservationConvention DEFAULT_OBSERVATION_CONVENTION = |
|
|
|
|
new DefaultClientRequestObservationConvention(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final ExchangeFunction exchangeFunction; |
|
|
|
|
|
|
|
|
@ -119,10 +121,10 @@ final class DefaultWebClient implements WebClient {
@@ -119,10 +121,10 @@ final class DefaultWebClient implements WebClient {
|
|
|
|
|
this.uriBuilderFactory = uriBuilderFactory; |
|
|
|
|
this.defaultHeaders = defaultHeaders; |
|
|
|
|
this.defaultCookies = defaultCookies; |
|
|
|
|
this.observationRegistry = observationRegistry; |
|
|
|
|
this.observationConvention = observationConvention; |
|
|
|
|
this.defaultRequest = defaultRequest; |
|
|
|
|
this.defaultStatusHandlers = initStatusHandlers(statusHandlerMap); |
|
|
|
|
this.observationRegistry = observationRegistry; |
|
|
|
|
this.observationConvention = observationConvention; |
|
|
|
|
this.builder = builder; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|