diff --git a/rsocket/src/test/java/com/baeldung/rsocket/RSocketIntegrationTest.java b/rsocket/src/test/java/com/baeldung/rsocket/RSocketIntegrationTest.java index 36f0b56fb4..afa3960eac 100644 --- a/rsocket/src/test/java/com/baeldung/rsocket/RSocketIntegrationTest.java +++ b/rsocket/src/test/java/com/baeldung/rsocket/RSocketIntegrationTest.java @@ -33,7 +33,9 @@ public class RSocketIntegrationTest { public void whenSendingAString_thenRevceiveTheSameString() { ReqResClient client = new ReqResClient(); String string = "Hello RSocket"; + assertEquals(string, client.callBlocking(string)); + client.dispose(); }