Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-19 23:04:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5780 from matrix-org/baboliver/loopingcall-args

Browse Source 
Add ability to pass arguments to looping calls
This commit is contained in:
Brendan Abolivier 2019-07-29 10:58:22 +02:00 committed by GitHub
commit fa87004bc1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
changelog.d/5780.misc Normal file
View File

@ -0,0 +1 @@
Allow looping calls to be given arguments.

6
synapse/util/__init__.py
View File

@ -59,7 +59,7 @@ class Clock(object):
"""Returns the current system time in miliseconds since epoch.""" """Returns the current system time in miliseconds since epoch."""
return int(self.time() * 1000) return int(self.time() * 1000)
def looping_call(self, f, msec): def looping_call(self, f, msec, *args, **kwargs):
"""Call a function repeatedly. """Call a function repeatedly.
Waits `msec` initially before calling `f` for the first time. Waits `msec` initially before calling `f` for the first time.
@ -70,8 +70,10 @@ class Clock(object):
Args: Args:
f(function): The function to call repeatedly. f(function): The function to call repeatedly.
msec(float): How long to wait between calls in milliseconds. msec(float): How long to wait between calls in milliseconds.
*args: Postional arguments to pass to function.
**kwargs: Key arguments to pass to function.
""" """
call = task.LoopingCall(f) call = task.LoopingCall(f, *args, **kwargs)
call.clock = self._reactor call.clock = self._reactor
d = call.start(msec / 1000.0, now=False) d = call.start(msec / 1000.0, now=False)
d.addErrback(log_failure, "Looping call died", consumeErrors=False) d.addErrback(log_failure, "Looping call died", consumeErrors=False)