summary refs log tree commit diff
path: root/synapse/handlers
diff options
context:
space:
mode:
authorNick Mills-Barrett <nick@beeper.com>2022-07-17 23:19:43 +0200
committerGitHub <noreply@github.com>2022-07-17 22:19:43 +0100
commit5d4028f217f178fcd384d5bfddd92225b4e78c51 (patch)
tree3123cad0bdeea027069318cbb12a1bb65b4dc7de /synapse/handlers
parentUse HTTPStatus constants in place of literals in tests. (#13297) (diff)
downloadsynapse-5d4028f217f178fcd384d5bfddd92225b4e78c51.tar.xz
Make all `process_replication_rows` methods async (#13304)
More prep work for asyncronous caching, also makes all process_replication_rows methods consistent (presence handler already is so).

Signed off by Nick @ Beeper (@Fizzadar)
Diffstat (limited to 'synapse/handlers')
-rw-r--r--synapse/handlers/typing.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/handlers/typing.py b/synapse/handlers/typing.py
index d104ea07fe..26edeeca3c 100644
--- a/synapse/handlers/typing.py
+++ b/synapse/handlers/typing.py
@@ -158,7 +158,7 @@ class FollowerTypingHandler:
         except Exception:
             logger.exception("Error pushing typing notif to remotes")
 
-    def process_replication_rows(
+    async def process_replication_rows(
         self, token: int, rows: List[TypingStream.TypingStreamRow]
     ) -> None:
         """Should be called whenever we receive updates for typing stream."""
@@ -444,7 +444,7 @@ class TypingWriterHandler(FollowerTypingHandler):
 
         return rows, current_id, limited
 
-    def process_replication_rows(
+    async def process_replication_rows(
         self, token: int, rows: List[TypingStream.TypingStreamRow]
     ) -> None:
         # The writing process should never get updates from replication.