Updates test to work around possible RSocket bug

2019-04-09 14:52:03 -04:00
parent a66e1b5e03
commit 15d4baf14d
1 changed files with 5 additions and 1 deletions
--- 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
@@ -16,6 +16,8 @@

 package org.springframework.cloud.gateway.rsocket.server;

+import java.time.Duration;
+
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.Test;
@@ -73,7 +75,9 @@ public class GatewayRSocketIntegrationTests {
 				.expectSubscription()
 				.then(() -> server.stop())
 				.thenConsumeWhile(s -> true)
-				.verifyComplete();
+				//.expectComplete()
+				.thenCancel()  // https://github.com/rsocket/rsocket-java/issues/613
+				.verify(Duration.ofSeconds(20));
 		// @formatter:on

 		assertThat(ping.getPongsReceived()).isGreaterThan(0);