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

remove Supervisor jobs, allow exceptions to stop the whole application

Browse source
This commit is contained in:
Adam 2022-05-14 12:55:33 +02:00
parent 7c77083c89
commit 775fd4c5b3
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -32,7 +32,7 @@ internal class KafkatorioTopology(
) : CoroutineScope { ) : CoroutineScope {
override val coroutineContext: CoroutineContext = override val coroutineContext: CoroutineContext =
Dispatchers.Default + SupervisorJob(rootJob) + CoroutineName("KafkatorioTopology") Dispatchers.Default + rootJob + CoroutineName("KafkatorioTopology")
fun start() { fun start() {
splitPackets() splitPackets()

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

@ -21,7 +21,7 @@ import org.http4k.websocket.WsStatus
class WebsocketServer { class WebsocketServer {
// create a scope+job for the server // create a scope+job for the server
private val serverJob = SupervisorJob() private val serverJob = KafkatorioTopology.rootJob
private val serverScope = CoroutineScope(serverJob) private val serverScope = CoroutineScope(serverJob)
private val clients: MutableSharedFlow<Websocket> = MutableSharedFlow( private val clients: MutableSharedFlow<Websocket> = MutableSharedFlow(