diff --git a/spring-messaging/spring-messaging.gradle b/spring-messaging/spring-messaging.gradle index d1a8f0cf31d..a98d5f3b9dc 100644 --- a/spring-messaging/spring-messaging.gradle +++ b/spring-messaging/spring-messaging.gradle @@ -7,7 +7,7 @@ dependencyManagement { } } -def rsocketVersion = "0.12.1-RC3-SNAPSHOT" +def rsocketVersion = "0.12.1-RC3" dependencies { compile(project(":spring-beans")) diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java index 267e197292f..0614e4c2cab 100644 --- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java +++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java @@ -138,7 +138,7 @@ public class RSocketBufferLeakTests { StepVerifier.create(result).expectErrorMatches(ex -> { String prefix = "Ambiguous handler methods mapped for destination 'A.B':"; return ex.getMessage().startsWith(prefix); - }).verify(); + }).verify(Duration.ofSeconds(5)); } @Test @@ -147,25 +147,25 @@ public class RSocketBufferLeakTests { StepVerifier.create(result).expectErrorMatches(ex -> { String prefix = "Cannot decode to [org.springframework.core.io.Resource]"; return ex.getMessage().contains(prefix); - }).verify(); + }).verify(Duration.ofSeconds(5)); } @Test public void errorSignalWithExceptionHandler() { Mono result = requester.route("error-signal").data("foo").retrieveMono(String.class); - StepVerifier.create(result).expectNext("Handled 'bad input'").verifyComplete(); + StepVerifier.create(result).expectNext("Handled 'bad input'").expectComplete().verify(Duration.ofSeconds(5)); } @Test public void ignoreInput() { Flux result = requester.route("ignore-input").data("a").retrieveFlux(String.class); - StepVerifier.create(result).expectNext("bar").verifyComplete(); + StepVerifier.create(result).expectNext("bar").thenCancel().verify(Duration.ofSeconds(5)); } @Test public void retrieveMonoFromFluxResponderMethod() { Mono result = requester.route("request-stream").data("foo").retrieveMono(String.class); - StepVerifier.create(result).expectNext("foo-1").verifyComplete(); + StepVerifier.create(result).expectNext("foo-1").expectComplete().verify(Duration.ofSeconds(5)); } diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java index 574ac0e5980..ac5698ffc76 100644 --- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java +++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java @@ -121,7 +121,8 @@ public class RSocketClientToServerIntegrationTests { StepVerifier.create(result) .expectNext("Hello 1").expectNext("Hello 2").expectNext("Hello 3") - .verifyComplete(); + .expectComplete() + .verify(Duration.ofSeconds(5)); } @Test @@ -131,7 +132,8 @@ public class RSocketClientToServerIntegrationTests { StepVerifier.create(result) .expectNext("Hello 1 async").expectNext("Hello 2 async").expectNext("Hello 3 async") - .verifyComplete(); + .expectComplete() + .verify(Duration.ofSeconds(5)); } @Test @@ -141,7 +143,7 @@ public class RSocketClientToServerIntegrationTests { StepVerifier.create(result) .expectNext("Hello 0").expectNextCount(6).expectNext("Hello 7") .thenCancel() - .verify(); + .verify(Duration.ofSeconds(5)); } @Test @@ -152,37 +154,46 @@ public class RSocketClientToServerIntegrationTests { StepVerifier.create(result) .expectNext("Hello 1 async").expectNextCount(8).expectNext("Hello 10 async") - .verifyComplete(); + .thenCancel() // https://github.com/rsocket/rsocket-java/issues/613 + .verify(Duration.ofSeconds(5)); } @Test public void voidReturnValue() { Flux result = requester.route("void-return-value").data("Hello").retrieveFlux(String.class); - StepVerifier.create(result).verifyComplete(); + StepVerifier.create(result).expectComplete().verify(Duration.ofSeconds(5)); } @Test public void voidReturnValueFromExceptionHandler() { Flux result = requester.route("void-return-value").data("bad").retrieveFlux(String.class); - StepVerifier.create(result).verifyComplete(); + StepVerifier.create(result).expectComplete().verify(Duration.ofSeconds(5)); } @Test public void handleWithThrownException() { Mono result = requester.route("thrown-exception").data("a").retrieveMono(String.class); - StepVerifier.create(result).expectNext("Invalid input error handled").verifyComplete(); + StepVerifier.create(result) + .expectNext("Invalid input error handled") + .expectComplete() + .verify(Duration.ofSeconds(5)); } @Test public void handleWithErrorSignal() { Mono result = requester.route("error-signal").data("a").retrieveMono(String.class); - StepVerifier.create(result).expectNext("Invalid input error handled").verifyComplete(); + StepVerifier.create(result) + .expectNext("Invalid input error handled") + .expectComplete() + .verify(Duration.ofSeconds(5)); } @Test public void noMatchingRoute() { Mono result = requester.route("invalid").data("anything").retrieveMono(String.class); - StepVerifier.create(result).verifyErrorMessage("No handler for destination 'invalid'"); + StepVerifier.create(result) + .expectErrorMessage("No handler for destination 'invalid'") + .verify(Duration.ofSeconds(5)); } diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketServerToClientIntegrationTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketServerToClientIntegrationTests.java index 17a4b8248c7..152e4e8974e 100644 --- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketServerToClientIntegrationTests.java +++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketServerToClientIntegrationTests.java @@ -151,7 +151,8 @@ public class RSocketServerToClientIntegrationTests { .expectNext("Hello 1") .expectNext("Hello 2") .expectNext("Hello 3") - .verifyComplete(); + .expectComplete() + .verify(Duration.ofSeconds(5)); }); } @@ -165,7 +166,8 @@ public class RSocketServerToClientIntegrationTests { .expectNext("Hello 1 async") .expectNext("Hello 2 async") .expectNext("Hello 3 async") - .verifyComplete(); + .expectComplete() + .verify(Duration.ofSeconds(5)); }); } @@ -180,7 +182,7 @@ public class RSocketServerToClientIntegrationTests { .expectNext("Hello 6") .expectNext("Hello 7") .thenCancel() - .verify(); + .verify(Duration.ofSeconds(5)); }); } @@ -196,7 +198,8 @@ public class RSocketServerToClientIntegrationTests { .expectNextCount(7) .expectNext("Hello 9 async") .expectNext("Hello 10 async") - .verifyComplete(); + .thenCancel() // https://github.com/rsocket/rsocket-java/issues/613 + .verify(Duration.ofSeconds(5)); }); }