diff options
author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-07-22 12:29:15 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-22 12:29:15 -0400 |
commit | cc9bb3dc3f299d451ab523dea192e48c32e87c68 (patch) | |
tree | b15225888161dd8c50f77249377fb0e58dc8cfb7 /tests/test_visibility.py | |
parent | Merge pull request #7934 from matrix-org/babolivier/acme_eol (diff) | |
download | synapse-cc9bb3dc3f299d451ab523dea192e48c32e87c68.tar.xz |
Convert the message handler to async/await. (#7884)
Diffstat (limited to 'tests/test_visibility.py')
-rw-r--r-- | tests/test_visibility.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/tests/test_visibility.py b/tests/test_visibility.py index f7381b2885..b371efc0df 100644 --- a/tests/test_visibility.py +++ b/tests/test_visibility.py @@ -53,7 +53,7 @@ class FilterEventsForServerTestCase(tests.unittest.TestCase): # # before we do that, we persist some other events to act as state. - self.inject_visibility("@admin:hs", "joined") + yield self.inject_visibility("@admin:hs", "joined") for i in range(0, 10): yield self.inject_room_member("@resident%i:hs" % i) @@ -137,8 +137,8 @@ class FilterEventsForServerTestCase(tests.unittest.TestCase): }, ) - event, context = yield self.event_creation_handler.create_new_client_event( - builder + event, context = yield defer.ensureDeferred( + self.event_creation_handler.create_new_client_event(builder) ) yield self.storage.persistence.persist_event(event, context) return event @@ -158,8 +158,8 @@ class FilterEventsForServerTestCase(tests.unittest.TestCase): }, ) - event, context = yield self.event_creation_handler.create_new_client_event( - builder + event, context = yield defer.ensureDeferred( + self.event_creation_handler.create_new_client_event(builder) ) yield self.storage.persistence.persist_event(event, context) @@ -179,8 +179,8 @@ class FilterEventsForServerTestCase(tests.unittest.TestCase): }, ) - event, context = yield self.event_creation_handler.create_new_client_event( - builder + event, context = yield defer.ensureDeferred( + self.event_creation_handler.create_new_client_event(builder) ) yield self.storage.persistence.persist_event(event, context) |