From 740036e8d968871e182e11f6d153624559be00bb Mon Sep 17 00:00:00 2001 From: InsanusMokrassar Date: Mon, 2 Nov 2020 21:44:12 +0600 Subject: [PATCH] link fix in ktor server --- .../dev/inmo/micro_utils/ktor/server/FlowsWebsocket.kt | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/ktor/server/FlowsWebsocket.kt b/ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/ktor/server/FlowsWebsocket.kt index 09fbb9bfcb5..7e951faf186 100644 --- a/ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/ktor/server/FlowsWebsocket.kt +++ b/ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/ktor/server/FlowsWebsocket.kt @@ -2,8 +2,7 @@ package dev.inmo.micro_utils.ktor.server import dev.inmo.micro_utils.coroutines.safely import dev.inmo.micro_utils.ktor.common.* -import io.ktor.http.cio.websocket.DefaultWebSocketSession -import io.ktor.http.cio.websocket.close +import io.ktor.http.cio.websocket.* import io.ktor.routing.Route import io.ktor.websocket.webSocket import kotlinx.coroutines.flow.Flow @@ -23,13 +22,11 @@ fun Route.includeWebsocketHandling( converter: (T) -> StandardKtorSerialInputData ) { webSocket(suburl) { -// println("connected") safely { flow.collect { send(converter(it)) } } -// println("disconnected") } }