SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

formatting

Browse Source
This commit is contained in:
Spencer Gibb
2019-03-11 14:59:47 -04:00
parent 8db8eaf793
commit a7bb9ad64e
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/WebClientHttpRoutingFilter.java
View File

@@ -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 -> {

7
spring-cloud-gateway-rsocket/src/test/java/org/springframework/cloud/gateway/rsocket/server/GatewayRSocketIntegrationTests.java
View File

@@ -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);