fix old

whyoleg · whyoleg · commit 69842970cc7d · 2025-02-25T20:39:32.000+02:00
diff --git a/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/core/RSocketServer.kt b/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/core/RSocketServer.kt
@@ -49,6 +49,7 @@ public class RSocketServer internal constructor(
     ): T = with(transport) {
         scope.start {
             acceptConnection(acceptor, OldConnection(interceptors.wrapConnection(it)))
+            awaitCancellation()
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,7 @@ public class RSocketServer internal constructor(`
`49`	`49`	`): T = with(transport) {`
`50`	`50`	`scope.start {`
`51`	`51`	`acceptConnection(acceptor, OldConnection(interceptors.wrapConnection(it)))`
	`52`	`+ awaitCancellation()`
`52`	`53`	`}`
`53`	`54`	`}`
`54`	`55`