forked from MirrorHub/synapse
Add a simple hook to wait for replication traffic
This commit is contained in:
parent
24d35ab47b
commit
7984708a55
|
@ -550,3 +550,9 @@ class Notifier(object):
|
||||||
break
|
break
|
||||||
|
|
||||||
defer.returnValue(result)
|
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()
|
||||||
|
|
Loading…
Reference in a new issue