We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3e219a0 commit 3c91f54Copy full SHA for 3c91f54
rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/connection/ConnectionEstablishmentHandler.kt
@@ -101,7 +101,7 @@ internal abstract class ConnectionEstablishmentHandler(
101
}
102
103
104
- override suspend fun RSocketConnection.initialize() {
105
- handleConnection(wrapConnection(this, coroutineContext.supervisorContext()))
+ override suspend fun RSocketConnection.initialize() = coroutineScope {
+ handleConnection(wrapConnection(this@initialize, coroutineContext.supervisorContext()))
106
107
0 commit comments