Ignoring stream closed error on session end

waicool20 · Feb 21, 2017 · a10dead · a10dead
1 parent 07f67cd
commit a10dead
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/src/main/kotlin/com/waicool20/kaga/util/StreamGobbler.kt b/src/main/kotlin/com/waicool20/kaga/util/StreamGobbler.kt
@@ -6,9 +6,16 @@ import java.io.InputStreamReader
 
 class StreamGobbler(val process: Process?) {
     fun run() {
-        val readOut = Thread { BufferedReader(InputStreamReader(process?.inputStream)).forEachLine(::println) }
-        val readErr = Thread { BufferedReader(InputStreamReader(process?.errorStream)).forEachLine(::println) }
-        readOut.start()
-        readErr.start()
+        val handler = Thread.UncaughtExceptionHandler { thread, throwable ->
+            if (throwable.message != "Stream closed") throw throwable // Ignore stream closed errors
+        }
+        with(Thread { BufferedReader(InputStreamReader(process?.inputStream)).forEachLine(::println) }) {
+            uncaughtExceptionHandler = handler
+            start()
+        }
+        with(Thread { BufferedReader(InputStreamReader(process?.errorStream)).forEachLine(::println) }) {
+            uncaughtExceptionHandler = handler
+            start()
+        }
     }
 }