Fix error responses handling in WebClient

bclozel · bclozel · commit 81125de6979b · 2017-09-14T14:15:05.000+02:00
This commit fixes a typo in the `DefaultWebClient` implementation.
Instead of forwarding resolved `WebClientException` instances as error
signals, the `bodyToMono(ParameterizedTypeReference)` variant would just
forward those exceptions as `onNext` signals.

Issue: SPR-15946
diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java
@@ -422,7 +422,7 @@ public <T> Mono<T> bodyToMono(Class<T> bodyType) {
 		public <T> Mono<T> bodyToMono(ParameterizedTypeReference<T> typeReference) {
 			return this.responseMono.flatMap(
 					response -> bodyToMono(response, BodyExtractors.toMono(typeReference),
-							mono -> (Mono<T>)mono));
+							this::monoThrowableToMono));
 		}
 
 		private <T> Mono<T> monoThrowableToMono(Mono<? extends Throwable> mono) {

Original file line number	Diff line number	Diff line change
`@@ -422,7 +422,7 @@ public <T> Mono<T> bodyToMono(Class<T> bodyType) {`
`422`	`422`	`public <T> Mono<T> bodyToMono(ParameterizedTypeReference<T> typeReference) {`
`423`	`423`	`return this.responseMono.flatMap(`
`424`	`424`	`response -> bodyToMono(response, BodyExtractors.toMono(typeReference),`
`425`		`- mono -> (Mono<T>)mono));`
	`425`	`+ this::monoThrowableToMono));`
`426`	`426`	`}`
`427`	`427`
`428`	`428`	`private <T> Mono<T> monoThrowableToMono(Mono<? extends Throwable> mono) {`