RSocket 예제 중 fire-and-forget, request-response 예제 추가

Author: debop

buildSrc/src/main/kotlin/Libraries.kt

@@ -356,7 +356,7 @@ object Libraries {
     const val junit_platform_commons = "org.junit.platform:junit-platform-commons:${Versions.junit_platform}"
     const val junit_platform_engine = "org.junit.platform:junit-platform-engine:${Versions.junit_platform}"
 
-    const val kluent = "org.amshove.kluent:kluent:1.52"
+    const val kluent = "org.amshove.kluent:kluent:1.62"
     const val assertj_core = "org.assertj:assertj-core:3.12.2"
     const val mockk = "io.mockk:mockk:1.9.3"
     const val mockito_core = "org.mockito:mockito-core:${Versions.mockito}"

rsocket/rsocket-communication/server/src/main/kotlin/io/github/debop/rsocket/server/RSocketController.kt

@@ -11,11 +11,10 @@ import javax.annotation.PreDestroy
 class RSocketController {
 
     companion object: KLogging() {
-
-        private const val SERVER = "Server"
-        private const val RESPONSE = "Response"
-        private const val STREAM = "Stream"
-        private const val CHANNEL = "Channel"
+        const val SERVER = "Server"
+        const val RESPONSE = "Response"
+        const val STREAM = "Stream"
+        const val CHANNEL = "Channel"
     }
 
     private val clients = mutableListOf<RSocketRequester>()

rsocket/rsocket-communication/server/src/test/kotlin/io/github/debop/rsocket/server/RSocketServerApplicationTest.kt

@@ -6,6 +6,7 @@ import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.runBlocking
 import mu.KLogging
+import org.amshove.kluent.shouldBeEqualTo
 import org.junit.jupiter.api.Test
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.rsocket.context.LocalRSocketServerPort
@@ -16,7 +17,8 @@ import org.springframework.messaging.rsocket.RSocketRequester
 import org.springframework.messaging.rsocket.RSocketStrategies
 import org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler
 import org.springframework.messaging.rsocket.connectTcpAndAwait
-import org.springframework.messaging.rsocket.retrieveMono
+import org.springframework.messaging.rsocket.retrieveAndAwait
+import org.springframework.messaging.rsocket.retrieveAndAwaitOrNull
 import java.util.UUID
 
 
@@ -41,7 +43,16 @@ class RSocketServerApplicationTest(
     fun `fire and forget`() = runBlocking<Unit> {
         val result = requester.route("fire-and-forget")
             .data(Message("TEST", "Fire-And-Forget"))
-            .retrieveMono<Void>()
+            .retrieveAndAwaitOrNull<Unit>()
+    }
+
+    @Test
+    fun `request get response`() = runBlocking<Unit> {
+        val result = requester.route("request-response")
+            .data(Message("TEST", "Request"))
+            .retrieveAndAwait<Message>()
+
+        result shouldBeEqualTo Message(RSocketController.SERVER, RSocketController.RESPONSE, 0)
     }
 
     class ClientHandler {

rsocket/rsocket-communication/server/src/test/resources/junit-platform.properties

@@ -17,4 +17,4 @@ junit.jupiter.testinstance.lifecycle.default = per_class
 
 junit.jupiter.execution.parallel.enabled = true
 junit.jupiter.execution.parallel.mode.default = concurrent
-junit.jupiter.execution.parallel.config.strategy = dynamic
+# junit.jupiter.execution.parallel.config.strategy = same_thread