introducing results_read signal - that is what's fired by read_all

django_performance_testing/serializer.py

@@ -1,5 +1,5 @@
 from django.utils.six.moves import cPickle as pickle
-from django_performance_testing.signals import results_collected
+from django_performance_testing.signals import results_collected, results_read
 
 
 class Reader:
@@ -11,7 +11,10 @@ def read_all(self):
             data = f.read()
         if not data:
             return []
-        return pickle.loads(data)
+        deserialized = pickle.loads(data)
+        for (sender, results, context) in deserialized:
+            results_read.send(sender=sender, results=results, context=context)
+        return deserialized
 
 
 class Writer:

django_performance_testing/signals.py

@@ -4,3 +4,5 @@
 results_collected = Signal(providing_args=('results', 'context'))
 
 before_clearing_queries_log = Signal(providing_args=['queries'])
+
+results_read = Signal(providing_args=('results', 'context'))

tests/testapp/tests/test_serialization.py

@@ -1,6 +1,6 @@
 import pytest
 from django_performance_testing import serializer
-from django_performance_testing.signals import results_collected
+from django_performance_testing.signals import results_collected, results_read
 from testapp.test_helpers import FakeSender, WithId
 
 
@@ -70,6 +70,31 @@ def test_writer_only_writes_when_end_is_called(tmpfilepath):
     assert deserialized == [(WithId('after start'), [2], {'after': 'start'})]
 
 
+def test_read_all_fires_results_read_signals(tmpfilepath):
+    writer = serializer.Writer(tmpfilepath)
+    writer.start()
+    results_collected.send(
+        sender=WithId('after start'), results=[2],
+        context={'after': 'start'})
+    writer.end()
+    results_from_results_read_signal = []
+
+    def record_read_results(sender, results, context, **kwargs):
+        results_from_results_read_signal.append((
+            sender, results, context
+        ))
+
+    results_read.connect(record_read_results)
+    reader = serializer.Reader(tmpfilepath)
+    deserialized = reader.read_all()
+    try:
+        assert deserialized != []
+        assert results_from_results_read_signal != []
+        assert results_from_results_read_signal == deserialized
+    finally:
+        results_read.disconnect(record_read_results)
+
+
 @pytest.mark.parametrize('sender_id,sender_type', [
         ('sender_id_1', 'sender_type_1'),
         ('sender_id_2', 'sender_type_2'),