diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/WebClient.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/WebClient.java index 530324d42b64..3e2fda8bed7d 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/WebClient.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/WebClient.java @@ -519,16 +519,13 @@ interface RequestHeadersSpec> { * scenarios, for example to decode the response differently depending * on the response status: *

-		 * Mono<Object> entityMono = client.get()
+		 * Mono<Person> entityMono = client.get()
 		 *     .uri("/persons/1")
 		 *     .accept(MediaType.APPLICATION_JSON)
 		 *     .exchangeToMono(response -> {
 		 *         if (response.statusCode().equals(HttpStatus.OK)) {
 		 *             return response.bodyToMono(Person.class);
 		 *         }
-		 *         else if (response.statusCode().is4xxClientError()) {
-		 *             return response.bodyToMono(ErrorContainer.class);
-		 *         }
 		 *         else {
 		 *             return response.createError();
 		 *         }
@@ -551,18 +548,15 @@ interface RequestHeadersSpec> {
 		 * scenarios, for example to decode the response differently depending
 		 * on the response status:
 		 * 

-		 * Mono<Object> entityMono = client.get()
+		 * Flux<Person> entityMono = client.get()
 		 *     .uri("/persons")
 		 *     .accept(MediaType.APPLICATION_JSON)
 		 *     .exchangeToFlux(response -> {
 		 *         if (response.statusCode().equals(HttpStatus.OK)) {
 		 *             return response.bodyToFlux(Person.class);
 		 *         }
-		 *         else if (response.statusCode().is4xxClientError()) {
-		 *             return response.bodyToMono(ErrorContainer.class).flux();
-		 *         }
 		 *         else {
-		 *             return response.createException().flux();
+		 *             return response.createError().flux();
 		 *         }
 		 *     });
 		 * 
diff --git a/src/docs/asciidoc/web/webflux-webclient.adoc b/src/docs/asciidoc/web/webflux-webclient.adoc index afa104ea8fbb..116480f985dc 100644 --- a/src/docs/asciidoc/web/webflux-webclient.adoc +++ b/src/docs/asciidoc/web/webflux-webclient.adoc @@ -582,17 +582,13 @@ depending on the response status: [source,java,indent=0,subs="verbatim,quotes",role="primary"] .Java ---- - Mono entityMono = client.get() + Mono entityMono = client.get() .uri("/persons/1") .accept(MediaType.APPLICATION_JSON) .exchangeToMono(response -> { if (response.statusCode().equals(HttpStatus.OK)) { return response.bodyToMono(Person.class); } - else if (response.statusCode().is4xxClientError()) { - // Suppress error status code - return response.bodyToMono(ErrorContainer.class); - } else { // Turn to error return response.createError(); @@ -609,9 +605,6 @@ val entity = client.get() if (response.statusCode() == HttpStatus.OK) { return response.awaitBody() } - else if (response.statusCode().is4xxClientError) { - return response.awaitBody() - } else { throw response.createExceptionAndAwait() }