close socket if null received

2022-07-06 16:21:07 +02:00 · 2022-07-06 16:21:07 +02:00 · d9e9e1af7d
commit d9e9e1af7d
parent 412cf15097
1 changed files with 6 additions and 2 deletions
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt
@ -64,8 +64,12 @@ class SyslogSocketServer(
              channel.readUTF8Line()
            }.fold(
              onSuccess = { line ->
-                if (line != null) {
-                  log("received '$line' from ${socket.description()}")
+                when (line) {
+                  null -> {
+                    log("received 'null' from ${socket.description()} - closing connection")
+                    socket.close()
+                  }
+                  else -> log("received '$line' from ${socket.description()}")
                }
                line
              },