summaryrefslogtreecommitdiff
path: root/src/leap/common/events/__init__.py
diff options
context:
space:
mode:
authorKali Kaneko <kali@leap.se>2015-09-16 12:20:22 -0400
committerKali Kaneko <kali@leap.se>2015-09-16 12:29:45 -0400
commit967763e8d0cc5f70f0760994d87500e30ad724a7 (patch)
tree0d8b8fd6246585b73726e052aa4844ab3850d9dc /src/leap/common/events/__init__.py
parentd4e4d3dc8ff88d98477e1fcd1104d7cd8b9e6612 (diff)
[refactor] move checking flag to main module
Diffstat (limited to 'src/leap/common/events/__init__.py')
-rw-r--r--src/leap/common/events/__init__.py19
1 files changed, 13 insertions, 6 deletions
diff --git a/src/leap/common/events/__init__.py b/src/leap/common/events/__init__.py
index 18d0ac8..f9ad5fa 100644
--- a/src/leap/common/events/__init__.py
+++ b/src/leap/common/events/__init__.py
@@ -41,6 +41,7 @@ import argparse
from leap.common.events import client
from leap.common.events import txclient
from leap.common.events import server
+from leap.common.events import flags
from leap.common.events.flags import set_events_enabled
from leap.common.events import catalog
@@ -78,11 +79,13 @@ def register(event, callback, uid=None, replace=False):
:raises CallbackAlreadyRegistered: when there's already a callback
identified by the given uid and replace is False.
"""
- return client.register(event, callback, uid, replace)
+ if flags.EVENTS_ENABLED:
+ return client.register(event, callback, uid, replace)
def register_async(event, callback, uid=None, replace=False):
- return txclient.register(event, callback, uid, replace)
+ if flags.EVENTS_ENABLED:
+ return txclient.register(event, callback, uid, replace)
def unregister(event, uid=None):
@@ -97,11 +100,13 @@ def unregister(event, uid=None):
:param uid: The callback uid.
:type uid: str
"""
- return client.unregister(event, uid)
+ if flags.EVENTS_ENABLED:
+ return client.unregister(event, uid)
def unregister_async(event, uid=None):
- return txclient.unregister(event, uid)
+ if flags.EVENTS_ENABLED:
+ return txclient.unregister(event, uid)
def emit(event, *content):
@@ -113,11 +118,13 @@ def emit(event, *content):
:param content: The content of the event.
:type content: list
"""
- return client.emit(event, *content)
+ if flags.EVENTS_ENABLED:
+ return client.emit(event, *content)
def emit_async(event, *content):
- return txclient.emit(event, *content)
+ if flags.EVENTS_ENABLED:
+ return txclient.emit(event, *content)
if __name__ == "__main__":