From b245918574024f4f0e576d984d3b336905d920e1 Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@pivotal.io>
Date: Thu, 6 Apr 2017 16:08:25 -0400
Subject: [PATCH] Fix compiler warning

---
 .../result/view/HttpMessageWriterView.java        | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/result/view/HttpMessageWriterView.java b/spring-webflux/src/main/java/org/springframework/web/reactive/result/view/HttpMessageWriterView.java
index 7e4108d182..d06ae82158 100644
--- a/spring-webflux/src/main/java/org/springframework/web/reactive/result/view/HttpMessageWriterView.java
+++ b/spring-webflux/src/main/java/org/springframework/web/reactive/result/view/HttpMessageWriterView.java
@@ -117,12 +117,7 @@ public class HttpMessageWriterView implements View {
 	@SuppressWarnings("unchecked")
 	public Mono<Void> render(Map<String, ?> model, MediaType contentType, ServerWebExchange exchange) {
 		return getObjectToRender(model)
-				.map(value -> {
-					Publisher stream = Mono.justOrEmpty(value);
-					ResolvableType type = ResolvableType.forClass(value.getClass());
-					ServerHttpResponse response = exchange.getResponse();
-					return this.writer.write(stream, type, contentType, response, Collections.emptyMap());
-				})
+				.map(value -> write(value, contentType, exchange))
 				.orElseGet(() -> exchange.getResponse().setComplete());
 	}
 
@@ -158,4 +153,12 @@ public class HttpMessageWriterView implements View {
 		return getMessageWriter().canWrite(type, null);
 	}
 
+	@SuppressWarnings("unchecked")
+	private <T> Mono<Void> write(T value, MediaType contentType, ServerWebExchange exchange) {
+		Publisher<T> input = Mono.justOrEmpty(value);
+		ResolvableType elementType = ResolvableType.forClass(value.getClass());
+		return ((HttpMessageWriter<T>) this.writer).write(
+				input, elementType, contentType, exchange.getResponse(), Collections.emptyMap());
+	}
+
 }