diff options
| author | Andrew Morgan <1342360+anoadragon453@users.noreply.github.com> | 2022-02-15 11:27:56 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-15 11:27:56 +0000 |
| commit | 87f200571386b131f841f8abc8bb08efb6c3be52 (patch) | |
| tree | e6648a124775d7fc033b4f8eb51552620f0e733b /synapse | |
| parent | Revert "Pin to frozendict<2.1.2 (#11625)" and allow frozendict>2.1.2 (#11969) (diff) | |
| download | synapse-87f200571386b131f841f8abc8bb08efb6c3be52.tar.xz | |
Add some tests for propagation of device list changes between local users (#11972)
Diffstat (limited to '')
| -rw-r--r-- | synapse/notifier.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index e0fad2da66..753dd6b6a5 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -138,7 +138,7 @@ class _NotifierUserStream: self.current_token = self.current_token.copy_and_advance(stream_key, stream_id) self.last_notified_token = self.current_token self.last_notified_ms = time_now_ms - noify_deferred = self.notify_deferred + notify_deferred = self.notify_deferred log_kv( { @@ -153,7 +153,7 @@ class _NotifierUserStream: with PreserveLoggingContext(): self.notify_deferred = ObservableDeferred(defer.Deferred()) - noify_deferred.callback(self.current_token) + notify_deferred.callback(self.current_token) def remove(self, notifier: "Notifier") -> None: """Remove this listener from all the indexes in the Notifier |