From a7bb9ad64e4da707c9cbae59d52ef26963ce8beb Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Mon, 11 Mar 2019 14:59:47 -0400 Subject: [PATCH] formatting --- .../cloud/gateway/filter/WebClientHttpRoutingFilter.java | 3 ++- .../rsocket/server/GatewayRSocketIntegrationTests.java | 7 +++++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/WebClientHttpRoutingFilter.java b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/WebClientHttpRoutingFilter.java index cecad879..199cd35f 100644 --- a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/WebClientHttpRoutingFilter.java +++ b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/WebClientHttpRoutingFilter.java @@ -88,7 +88,8 @@ public class WebClientHttpRoutingFilter implements GlobalFilter, Ordered { HttpHeaders filteredHeaders = filterRequest(getHeadersFilters(), exchange); - boolean preserveHost = exchange.getAttributeOrDefault(PRESERVE_HOST_HEADER_ATTRIBUTE, false); + boolean preserveHost = exchange + .getAttributeOrDefault(PRESERVE_HOST_HEADER_ATTRIBUTE, false); RequestBodySpec bodySpec = this.webClient.method(method).uri(requestUrl) .headers(httpHeaders -> { diff --git a/spring-cloud-gateway-rsocket/src/test/java/org/springframework/cloud/gateway/rsocket/server/GatewayRSocketIntegrationTests.java b/spring-cloud-gateway-rsocket/src/test/java/org/springframework/cloud/gateway/rsocket/server/GatewayRSocketIntegrationTests.java index c4dfb6bf..09cf2a89 100644 --- a/spring-cloud-gateway-rsocket/src/test/java/org/springframework/cloud/gateway/rsocket/server/GatewayRSocketIntegrationTests.java +++ b/spring-cloud-gateway-rsocket/src/test/java/org/springframework/cloud/gateway/rsocket/server/GatewayRSocketIntegrationTests.java @@ -68,8 +68,11 @@ public class GatewayRSocketIntegrationTests { @Test public void contextLoads() { - StepVerifier.create(ping.getPongFlux()).expectSubscription() - .then(() -> server.stop()).thenConsumeWhile(s -> true).verifyComplete(); + StepVerifier.create(ping.getPongFlux()) + .expectSubscription() + .then(() -> server.stop()) + .thenConsumeWhile(s -> true) + .verifyComplete(); assertThat(ping.getPongsReceived()).isGreaterThan(0); assertThat(pong.getPingsReceived()).isGreaterThan(0);