diff --git a/src/video_rxtx.cpp b/src/video_rxtx.cpp
index a09276606..9b9cdf474 100644
--- a/src/video_rxtx.cpp
+++ b/src/video_rxtx.cpp
@@ -112,6 +112,10 @@ video_rxtx::video_rxtx(map<string, param_u> const &params): m_port_id("default")
 
 video_rxtx::~video_rxtx() {
         join();
+        if (!m_poisoned && m_compression) {
+                send(NULL);
+                compress_pop(m_compression);
+        }
         module_done(CAST_MODULE(m_compression));
         module_done(&m_receiver_mod);
         module_done(&m_sender_mod);