From 4aea551e8eab0cd754ff4caf993de6db9104c327 Mon Sep 17 00:00:00 2001
From: Kamil Szymanski <kamil.szymanski.dev@gmail.com>
Date: Sat, 30 Jul 2016 00:29:55 +0200
Subject: [PATCH] Use abbreviated expression lambda instead of statement lambda

Closes gh-1126
---
 .../http/server/reactive/RxNettyServerHttpResponse.java   | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java b/spring-web/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java
index 53f73da4b3..75758fcd64 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java
@@ -82,11 +82,9 @@ public class RxNettyServerHttpResponse extends AbstractServerHttpResponse {
 	protected Mono<Void> writeAndFlushWithInternal(
 			Publisher<Publisher<DataBuffer>> body) {
 		Flux<ByteBuf> bodyWithFlushSignals = Flux.from(body).
-				flatMap(publisher -> {
-					return Flux.from(publisher).
-							map(NettyDataBufferFactory::toByteBuf).
-							concatWith(Mono.just(FLUSH_SIGNAL));
-				});
+				flatMap(publisher -> Flux.from(publisher).
+						map(NettyDataBufferFactory::toByteBuf).
+						concatWith(Mono.just(FLUSH_SIGNAL)));
 		Observable<ByteBuf> content = RxJava1Adapter.publisherToObservable(bodyWithFlushSignals);
 		ResponseContentWriter<ByteBuf> writer = this.response.write(content, bb -> bb == FLUSH_SIGNAL);
 		return RxJava1Adapter.observableToFlux(writer).then();