1 files changed, 3 insertions, 1 deletions
diff --git a/src/handler.h b/src/handler.h
index 8f4d71b9..bfb1b08f 100644
--- a/src/handler.h
+++ b/src/handler.h
@@ -78,8 +78,10 @@ public:
       handler->flush();
   }
   virtual void operator()(T& item) {
-    if (handler.get())
+    if (handler.get()) {
+      check_for_signal();
       (*handler.get())(item);
+    }
   }
 };