Ensure Reactor & RxJava response extractors compile with Eclipse JDT

Author: sbrannen

spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java

@@ -65,7 +65,6 @@ public static <T> ResponseExtractor<Mono<T>> body(Class<T> sourceClass) {
 	 * Extract the response body and decode it, returning it as a {@code Mono<T>}.
 	 * @see ResolvableType#forClassWithGenerics(Class, Class[])
 	 */
-	@SuppressWarnings("unchecked")
 	public static <T> BodyExtractor<Mono<T>> as(ResolvableType bodyType) {
 		return (clientResponse, messageConverters) ->
 				decodeResponseBodyAsMono(clientResponse, bodyType, messageConverters);
@@ -153,7 +152,8 @@ public static <T> ResponseExtractor<Mono<ResponseEntity<T>>> response(Class<T> b
 	public static <T> ResponseExtractor<Mono<ResponseEntity<Flux<T>>>> responseStream(ResolvableType type) {
 		return (clientResponse, webClientConfig) -> clientResponse
 				.map(response -> new ResponseEntity<>(
-						decodeResponseBody(response, type, webClientConfig.getMessageReaders()),
+						// ResponseExtractors.<T> is required for Eclipse JDT.
+						ResponseExtractors.<T> decodeResponseBody(response, type, webClientConfig.getMessageReaders()),
 						response.getHeaders(), response.getStatusCode()));
 	}
 

spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java

@@ -60,9 +60,7 @@ public static <T> ResponseExtractor<Single<T>> body(ResolvableType bodyType) {
 	/**
 	 * Extract the response body and decode it, returning it as a {@code Single<T>}.
 	 */
-	@SuppressWarnings("unchecked")
 	public static <T> ResponseExtractor<Single<T>> body(Class<T> sourceClass) {
-
 		ResolvableType bodyType = ResolvableType.forClass(sourceClass);
 		return body(bodyType);
 	}
@@ -174,7 +172,9 @@ public static <T> ResponseExtractor<Single<ResponseEntity<Observable<T>>>> respo
 		return (clientResponse, webClientConfig) -> RxJava1Adapter.publisherToSingle(clientResponse
 				.map(response -> new ResponseEntity<>(
 								RxJava1Adapter
-								.publisherToObservable(decodeResponseBody(response, bodyType, webClientConfig.getMessageReaders())),
+								.publisherToObservable(
+										// RxJava1ResponseExtractors.<T> is required for Eclipse JDT.
+										RxJava1ResponseExtractors.<T> decodeResponseBody(response, bodyType, webClientConfig.getMessageReaders())),
 						response.getHeaders(),
 						response.getStatusCode())));
 	}