1 files changed, 6 insertions, 0 deletions
diff --git a/src/InputReader.h b/src/InputReader.h
index 8917922..015303d 100644
--- a/src/InputReader.h
+++ b/src/InputReader.h
@@ -164,6 +164,11 @@ class InputZeroMQReader : public InputReader
             workerdata_.in_messages = &in_messages_;
         }
 
+        ~InputZeroMQReader()
+        {
+            worker_.Stop();
+        }
+
         int Open(std::string uri);
 
         int GetNextFrame(void* buffer);
@@ -171,6 +176,7 @@ class InputZeroMQReader : public InputReader
         void PrintInfo();
 
     private:
+        InputZeroMQReader(const InputZeroMQReader& other) {}
         Logger logger_;
         std::string uri_;