diff options
| -rw-r--r-- | synapse/notifier.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index 7eeba6d28e..f9fcc0ca25 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -550,3 +550,9 @@ class Notifier(object): break defer.returnValue(result) + + def wait_once_for_replication(self): + """Returns a deferred which resolves when there is new data for + replication to handle. + """ + return self.replication_deferred.observe() |