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 09cf2a89..a1cb6d0b 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,11 +68,13 @@ public class GatewayRSocketIntegrationTests { @Test public void contextLoads() { + // @formatter:off StepVerifier.create(ping.getPongFlux()) .expectSubscription() .then(() -> server.stop()) .thenConsumeWhile(s -> true) .verifyComplete(); + // @formatter:on assertThat(ping.getPongsReceived()).isGreaterThan(0); assertThat(pong.getPingsReceived()).isGreaterThan(0);