1 files changed, 4 insertions, 0 deletions
diff --git a/src/GSTInput.cpp b/src/GSTInput.cpp
index aa46003..a2401cb 100644
--- a/src/GSTInput.cpp
+++ b/src/GSTInput.cpp
@@ -271,6 +271,10 @@ void GSTInput::process()
 GSTInput::~GSTInput()
 {
     m_running = false;
+
+    // Ensures push() doesn't get blocked
+    m_gst_data.samplequeue.clear();
+
     if (m_thread.joinable()) {
         m_thread.join();
     }