From a70e525dc80bb60d9d8d5e94124bb2c920384cfd Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@vmware.com>
Date: Fri, 2 Jul 2021 20:26:25 +0100
Subject: [PATCH] Fix formatting

---
 .../web/webflux/GraphQlHttpHandler.java       | 38 ++++++++++---------
 1 file changed, 20 insertions(+), 18 deletions(-)

diff --git a/spring-graphql/src/main/java/org/springframework/graphql/web/webflux/GraphQlHttpHandler.java b/spring-graphql/src/main/java/org/springframework/graphql/web/webflux/GraphQlHttpHandler.java
index 63683f1b..9d28b553 100644
--- a/spring-graphql/src/main/java/org/springframework/graphql/web/webflux/GraphQlHttpHandler.java
+++ b/spring-graphql/src/main/java/org/springframework/graphql/web/webflux/GraphQlHttpHandler.java
@@ -61,24 +61,26 @@ public class GraphQlHttpHandler {
 	 * @return the HTTP response
 	 */
 	public Mono<ServerResponse> handleRequest(ServerRequest request) {
-		return request.bodyToMono(MAP_PARAMETERIZED_TYPE_REF).flatMap((body) -> {
-			String id = request.exchange().getRequest().getId();
-			WebInput input = new WebInput(request.uri(), request.headers().asHttpHeaders(), body, id);
-			if (logger.isDebugEnabled()) {
-				logger.debug("Executing: " + input);
-			}
-			return this.graphQlHandler.handle(input);
-		}).flatMap((output) -> {
-			Map<String, Object> spec = output.toSpecification();
-			if (logger.isDebugEnabled()) {
-				logger.debug("Execution complete");
-			}
-			ServerResponse.BodyBuilder builder = ServerResponse.ok();
-			if (output.getResponseHeaders() != null) {
-				builder.headers((headers) -> headers.putAll(output.getResponseHeaders()));
-			}
-			return builder.bodyValue(spec);
-		});
+		return request.bodyToMono(MAP_PARAMETERIZED_TYPE_REF)
+				.flatMap((body) -> {
+					String id = request.exchange().getRequest().getId();
+					WebInput input = new WebInput(request.uri(), request.headers().asHttpHeaders(), body, id);
+					if (logger.isDebugEnabled()) {
+						logger.debug("Executing: " + input);
+					}
+					return this.graphQlHandler.handle(input);
+				})
+				.flatMap((output) -> {
+					Map<String, Object> spec = output.toSpecification();
+					if (logger.isDebugEnabled()) {
+						logger.debug("Execution complete");
+					}
+					ServerResponse.BodyBuilder builder = ServerResponse.ok();
+					if (output.getResponseHeaders() != null) {
+						builder.headers((headers) -> headers.putAll(output.getResponseHeaders()));
+					}
+					return builder.bodyValue(spec);
+				});
 	}
 
 }