wip try to debug tests

rsocket · Mar 14, 2024 · bdf2f9f · bdf2f9f
1 parent f917dc0
commit bdf2f9f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/operation/OperationInbound.kt b/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/operation/OperationInbound.kt
@@ -52,7 +52,10 @@ internal class OperationFrameHandler(private val inbound: OperationInbound) : Cl
     }
 
     fun handleFrame(frame: Frame) {
-        if (!inbound.isFrameExpected(frame.type)) return frame.close()
+        if (!inbound.isFrameExpected(frame.type)) {
+            println("unexpected frame: $frame")
+            return frame.close()
+        }
 
         when (frame) {
             is CancelFrame   -> inbound.receiveCancel()

diff --git a/...-transport-tests/src/commonMain/kotlin/io/rsocket/kotlin/transport/tests/TransportTest.kt b/...-transport-tests/src/commonMain/kotlin/io/rsocket/kotlin/transport/tests/TransportTest.kt
@@ -33,7 +33,7 @@ import kotlin.time.Duration.Companion.seconds
 //TODO: need to somehow rework those tests, as now they are super flaky
 // there is some issue in K/N tcp...
 abstract class TransportTest : SuspendTest, TestWithLeakCheck {
-    override val testTimeout: Duration = 5.minutes
+    override val testTimeout: Duration = 1.minutes
 
     private val testJob = SupervisorJob()
     protected val testContext = testJob + TestExceptionHandler
@@ -54,7 +54,7 @@ abstract class TransportTest : SuspendTest, TestWithLeakCheck {
         SERVER.start(serverTransport, ACCEPTOR)
 
     override suspend fun after() {
-        client.coroutineContext.job.cancelAndJoin()
+        //client.coroutineContext.job.cancelAndJoin()
         testJob.cancelAndJoin()
     }