lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

project version bump to 0.6.0, and bump kotest, tstl, typescript

Browse source
This commit is contained in:
Adam 2022-06-19 10:54:37 +02:00
parent a225b65901
commit 0398e2026d
11 changed files with 74 additions and 88 deletions
Download patch file Download diff file Expand all files Collapse all files

6
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
View file

@ -50,9 +50,3 @@ suspend fun main() {
}
}
}
// Runtime.getRuntime().addShutdownHook(Thread {
// webServer.stop()
// })
// launch {
// }
//}

2
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/tileserver/WebServer.kt
View file

@ -6,7 +6,7 @@ import org.http4k.server.PolyHandler
import org.http4k.server.Undertow
import org.http4k.server.asServer
internal suspend fun webServer(
internal fun webServer(
tileServer: WebMapTileServer,
wsServer: WebsocketServer,
appProps: ApplicationProperties,

9
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/tileserver/WebsocketServer.kt
View file

@ -98,10 +98,7 @@ class WebsocketServer {
val clientJob = SupervisorJob(serverScope.coroutineContext.job)
serverScope.launch(CoroutineName("ws-client-$id") + clientJob) {
// return serverScope.launch(CoroutineName("ws-client-$id")) {
// supervisorScope {
launch {
suspendCancellableCoroutine<WsStatus> { cont ->
println("[ws-client] entering suspendCancellableCoroutine")
@ -138,11 +135,7 @@ class WebsocketServer {
.onEach { msg ->
println("[ws-client] sending message to $id")
ws.send(WsMessage(msg))
}
.launchIn(this)
}.launchIn(this)
}
// }
}
}