Catch exceptions in Stream.stop()

2018-09-09 19:23:42 +02:00 · 2018-09-09 19:23:42 +02:00 · 01aa04b3da
parent 42186208bf
commit 01aa04b3da
1 changed files with 6 additions and 2 deletions
--- a/src/main/java/org/taktik/mpegts/Streamer.java
+++ b/src/main/java/org/taktik/mpegts/Streamer.java
@ -77,8 +77,12 @@ public class Streamer {
            log.error("Couldn't close sink", e);
        }
        buffer.clear();
-        bufferingThread.interrupt();
-        streamingThread.interrupt();
+        try {
+            bufferingThread.interrupt();
+            streamingThread.interrupt();
+        } catch (Exception e) {
+            log.error("Couldn't interrupt streamer threads");
+        }
    }

    private void internalStream() {