Fix bug in _send_and_delete_signal_instances()

epandurski · Jun 26, 2019 · a5d95ef · a5d95ef
1 parent 2173a22
commit a5d95ef
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/flask_signalbus/signalbus.py b/flask_signalbus/signalbus.py
@@ -273,10 +273,8 @@ def _get_signal_burst_count(self, model):
 
     def _send_and_delete_signal_instances(self, model, instances):
         n = len(instances)
-        if n > 1:
-            send_signalbus_messages = getattr(model, 'send_signalbus_messages', None)
-            if send_signalbus_messages:
-                send_signalbus_messages(instances)
+        if n > 1 and hasattr(model, 'send_signalbus_messages'):
+            model.send_signalbus_messages(instances)
         else:
             for instance in instances:
                 instance.send_signalbus_message()