fix QUIC implementation (#283)

rsocket · Nov 30, 2024 · 66873a3 · 66873a3
1 parent b7f27ba
commit 66873a3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/rsocket-test/src/commonMain/kotlin/io/rsocket/kotlin/test/SuspendTest.kt b/rsocket-test/src/commonMain/kotlin/io/rsocket/kotlin/test/SuspendTest.kt
@@ -24,7 +24,14 @@ import kotlin.time.Duration.Companion.minutes
 import kotlin.time.Duration.Companion.seconds
 
 val TestExceptionHandler = CoroutineExceptionHandler { c, e ->
-    println("Error in $c -> ${e.stackTraceToString()}")
+    val message = buildString {
+        appendLine("TestExceptionHandler:")
+        appendLine("  context: $c")
+        appendLine("  cause: $e")
+        appendLine("  stackTrace:")
+        e.stackTraceToString().lines().forEach { appendLine("  $it") }
+    }
+    println(message)
 }
 
 interface SuspendTest {

diff --git a/...-quic/src/jvmMain/kotlin/io/rsocket/kotlin/transport/netty/quic/NettyQuicStreamHandler.kt b/...-quic/src/jvmMain/kotlin/io/rsocket/kotlin/transport/netty/quic/NettyQuicStreamHandler.kt
@@ -83,8 +83,6 @@ internal class NettyQuicStreamHandler(
             state.inbound.cancel()
             withContext(NonCancellable) {
                 writerJob.join()
-                // TODO: what is the correct way to properly shutdown stream?
-                channel.shutdownInput().awaitFuture()
                 channel.close().awaitFuture()
             }
         }