From 455dea97d9c5e141e89d3ae115235b2c260b3a8a Mon Sep 17 00:00:00 2001
From: 0xboobface <0xboobface@gmail.com>
Date: Sun, 9 Sep 2018 14:28:29 +0200
Subject: [PATCH] Try not to write to sink, if the streamer has been stopped

---
 src/main/java/org/taktik/mpegts/Streamer.java | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/taktik/mpegts/Streamer.java b/src/main/java/org/taktik/mpegts/Streamer.java
index c5db16ec..ebd536b0 100644
--- a/src/main/java/org/taktik/mpegts/Streamer.java
+++ b/src/main/java/org/taktik/mpegts/Streamer.java
@@ -65,6 +65,7 @@ public class Streamer {
     }
 
     public void stop() {
+        streamingShouldStop = true;
         try {
             source.close();
         } catch (Exception e) {
@@ -75,7 +76,6 @@ public class Streamer {
         } catch (Exception e) {
             log.error("Couldn't close sink", e);
         }
-        streamingShouldStop = true;
         buffer.clear();
         bufferingThread.interrupt();
         streamingThread.interrupt();
@@ -232,10 +232,12 @@ public class Streamer {
             // Stream packet
             // System.out.println("Streaming packet #" + packetCount + ", PID=" + mtsPacket.getPid() + ", pcrCount=" + pcrCount + ", continuityCounter=" + mtsPacket.getContinuityCounter());
 
-            try {
-                sink.send(packet);
-            } catch (Exception e) {
-                log.error("Error sending packet to sink", e);
+            if(!streamingShouldStop) {
+                try {
+                    sink.send(packet);
+                } catch (Exception e) {
+                    log.error("Error sending packet to sink", e);
+                }
             }
 
             packetCount++;