@@ -16,7 +16,6 @@ import io.helidon.webserver.staticcontent.StaticContentService
1616import io.ktor.client.*
1717import io.ktor.client.engine.cio.*
1818import io.ktor.client.plugins.websocket.*
19- import io.ktor.http.*
2019import io.ktor.utils.io.core.*
2120import io.rsocket.kotlin.RSocket
2221import io.rsocket.kotlin.core.WellKnownMimeType
@@ -26,6 +25,11 @@ import io.rsocket.kotlin.ktor.client.rSocket
2625import io.rsocket.kotlin.payload.PayloadMimeType
2726import io.rsocket.kotlin.payload.buildPayload
2827import io.rsocket.kotlin.payload.data
28+ import kotlinx.coroutines.asCoroutineDispatcher
29+ import kotlinx.coroutines.flow.flowOn
30+ import kotlinx.coroutines.flow.take
31+ import kotlinx.coroutines.runBlocking
32+ import org.graalvm.nativeimage.ImageInfo
2933import java.io.File
3034import java.lang.System.Logger.Level.INFO
3135import java.lang.management.ManagementFactory
@@ -58,11 +62,6 @@ import kotlin.jvm.optionals.getOrDefault
5862import kotlin.system.exitProcess
5963import kotlin.time.Duration.Companion.minutes
6064import kotlin.time.Duration.Companion.seconds
61- import kotlinx.coroutines.asCoroutineDispatcher
62- import kotlinx.coroutines.flow.flowOn
63- import kotlinx.coroutines.flow.take
64- import kotlinx.coroutines.runBlocking
65- import org.graalvm.nativeimage.ImageInfo
6665
6766val logger = System .getLogger(" Main" )
6867val vtDispatcher by lazy { Executors .newVirtualThreadPerTaskExecutor().asCoroutineDispatcher() }
0 commit comments