summary refs log tree commit diff
path: root/tests
diff options
context:
space:
mode:
Diffstat (limited to 'tests')
-rw-r--r--tests/appservice/test_scheduler.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/appservice/test_scheduler.py b/tests/appservice/test_scheduler.py
index e18e879319..4534d05b93 100644
--- a/tests/appservice/test_scheduler.py
+++ b/tests/appservice/test_scheduler.py
@@ -213,7 +213,7 @@ class ApplicationServiceSchedulerEventGrouperTestCase(unittest.TestCase):
     def test_drain_single_event(self):
         service = Mock()
         event = Mock()
-        self.grouper.on_receive(service, event)
+        self.grouper.enqueue(service, event)
         groups = self.grouper.drain_groups()
         self.assertTrue(service in groups)
         self.assertEquals([event], groups[service])
@@ -225,7 +225,7 @@ class ApplicationServiceSchedulerEventGrouperTestCase(unittest.TestCase):
         service = Mock()
         events = [Mock(), Mock(), Mock()]
         for e in events:
-            self.grouper.on_receive(service, e)
+            self.grouper.enqueue(service, e)
         groups = self.grouper.drain_groups()
         self.assertTrue(service in groups)
         self.assertEquals(events, groups[service])
@@ -243,11 +243,11 @@ class ApplicationServiceSchedulerEventGrouperTestCase(unittest.TestCase):
             services[2]: events_c
         }
         for e in events_b:
-            self.grouper.on_receive(services[1], e)
+            self.grouper.enqueue(services[1], e)
         for e in events_c:
-            self.grouper.on_receive(services[2], e)
+            self.grouper.enqueue(services[2], e)
         for e in events_a:
-            self.grouper.on_receive(services[0], e)
+            self.grouper.enqueue(services[0], e)
 
         groups = self.grouper.drain_groups()
         for service in services: