diff --git a/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java b/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java
index c55253c37b1..ca835fc6e4e 100644
--- a/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java
+++ b/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java
@@ -117,8 +117,7 @@ public class ResponseExtractors {
 			ResolvableType type) {
 		return (clientResponse, messageConverters) -> clientResponse
 				.map(response -> new ResponseEntity<>(
-						decodeResponseBody(response, type,
-								messageConverters),
+						ResponseExtractors.<T> decodeResponseBody(response, type, messageConverters),
 						response.getHeaders(), response.getStatusCode()));
 	}
 
diff --git a/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java b/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java
index 4a6a4935ef1..b12263f9681 100644
--- a/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java
+++ b/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java
@@ -90,10 +90,10 @@ public class 	RxJava1ResponseExtractors {
 	 */
 	public static <T> ResponseExtractor<Single<ResponseEntity<Observable<T>>>> responseStream(Class<T> sourceClass) {
 		ResolvableType resolvableType = ResolvableType.forClass(sourceClass);
-		return (clientResponse, messageConverters) -> RxJava1SingleConverter.fromPublisher(clientResponse
-				.map(response -> new ResponseEntity<>(
-						RxJava1ObservableConverter
-								.fromPublisher(decodeResponseBody(response, resolvableType, messageConverters)),
+		return (clientResponse, messageConverters) -> RxJava1SingleConverter.fromPublisher(
+				clientResponse.map(response -> new ResponseEntity<>(
+						RxJava1ObservableConverter.fromPublisher(
+								RxJava1ResponseExtractors.<T> decodeResponseBody(response, resolvableType, messageConverters)),
 						response.getHeaders(),
 						response.getStatusCode())));
 	}