diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2021-07-28 20:55:50 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-07-28 19:55:50 +0000 |
| commit | 858363d0b7e58fd71875b25d183537bb3b5a397f (patch) | |
| tree | 080bc8232ee759309c29ee50c875e4bcddd39b2f /synapse/notifier.py | |
| parent | Make historical events discoverable from backfill for servers without any scr... (diff) | |
| download | synapse-858363d0b7e58fd71875b25d183537bb3b5a397f.tar.xz | |
Generics for `ObservableDeferred` (#10491)
Now that `Deferred` is a generic class, let's update `ObeservableDeferred` to follow suit.
Diffstat (limited to 'synapse/notifier.py')
| -rw-r--r-- | synapse/notifier.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index c5fbebc17d..bbe337949a 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -111,8 +111,9 @@ class _NotifierUserStream: self.last_notified_token = current_token self.last_notified_ms = time_now_ms - with PreserveLoggingContext(): - self.notify_deferred = ObservableDeferred(defer.Deferred()) + self.notify_deferred: ObservableDeferred[StreamToken] = ObservableDeferred( + defer.Deferred() + ) def notify( self, |