Added error catching as asked for in issue dzikoysk#1604

P-DR0ZD · Oct 14, 2022 · 221ac8c · 221ac8c
1 parent 40aeca7
commit 221ac8c
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...-backend/src/main/kotlin/com/reposilite/console/infrastructure/ConsoleWebSocketHandler.kt b/...-backend/src/main/kotlin/com/reposilite/console/infrastructure/ConsoleWebSocketHandler.kt
@@ -66,7 +66,12 @@ internal class CliEndpoint(
                             journalist.logger.info("CLI | $identifier accessed remote console")
 
                             val subscriberId = journalist.subscribe {
-                                ctx.send(it.value)
+                                try{
+                                    ctx.send(it.value)
+                                }
+                                catch(e: java.nio.channels.ClosedChannelException) {
+                                    journalist.logger.debug("CLI | $identifier tried to access a Closed Channel ")
+                                }
                             }
 
                             users[ctx] = WsSession(identifier, subscriberId)