1 files changed, 3 insertions, 0 deletions
diff --git a/src/FileInput.cpp b/src/FileInput.cpp
index 51b0456..517ea7d 100644
--- a/src/FileInput.cpp
+++ b/src/FileInput.cpp
@@ -27,6 +27,9 @@ using namespace std;
 
 FileInput::~FileInput()
 {
+    // Ensures push() doesn't get blocked
+    m_queue.clear();
+
     if (m_raw_input and m_in_fh) {
         fclose(m_in_fh);
     }