diff --git a/spring-web/src/main/java/org/springframework/http/codec/xml/XmlEventDecoder.java b/spring-web/src/main/java/org/springframework/http/codec/xml/XmlEventDecoder.java
index 8ded46a9c3c..fe7cf5b7b8b 100644
--- a/spring-web/src/main/java/org/springframework/http/codec/xml/XmlEventDecoder.java
+++ b/spring-web/src/main/java/org/springframework/http/codec/xml/XmlEventDecoder.java
@@ -137,7 +137,7 @@ public class XmlEventDecoder extends AbstractDecoder<XMLEvent> {
 		if (this.useAalto) {
 			AaltoDataBufferToXmlEvent mapper = new AaltoDataBufferToXmlEvent(hints);
 			return Flux.from(input)
-					.flatMapIterable(mapper)
+					.<XMLEvent>flatMapIterable(mapper)
 					.doFinally(signalType -> mapper.endOfInput());
 		}
 		else {
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
index 3cc7f07e57d..ed67c41f355 100644
--- 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
@@ -681,14 +681,14 @@ final class DefaultWebClient implements WebClient {
 		}
 
 		private <T> Publisher<T> handleBodyFlux(ClientResponse response, Flux<T> body) {
-			body = body.onErrorResume(WebClientUtils.WRAP_EXCEPTION_PREDICATE, exceptionWrappingFunction(response));
+			body = body.onErrorResume(WebClientUtils.WRAP_EXCEPTION_PREDICATE, this.<T>exceptionWrappingFunction(response));
 			Mono<T> result = applyStatusHandlers(response);
 			return (result != null ? result.flux().switchIfEmpty(body) : body);
 		}
 
 		private <T> Mono<? extends ResponseEntity<Flux<T>>> handlerEntityFlux(ClientResponse response, Flux<T> body) {
 			ResponseEntity<Flux<T>> entity = new ResponseEntity<>(
-					body.onErrorResume(WebClientUtils.WRAP_EXCEPTION_PREDICATE, exceptionWrappingFunction(response)),
+					body.onErrorResume(WebClientUtils.WRAP_EXCEPTION_PREDICATE, this.<T>exceptionWrappingFunction(response)),
 					response.headers().asHttpHeaders(),
 					response.statusCode());