summaryrefslogtreecommitdiff
path: root/src/leap/common/events/client.py
diff options
context:
space:
mode:
authorKali Kaneko <kali@leap.se>2015-09-24 15:18:46 -0400
committerKali Kaneko <kali@leap.se>2015-09-24 15:18:46 -0400
commitfdd3382169d39abd00c035a5be11b20c6fdc588d (patch)
treee9598a74b9016f32cf34f858dd4ef76a788ced2e /src/leap/common/events/client.py
parent56724056f95e3d908c3fd11840cf62e64afb9e0f (diff)
parentd3519a062ea6924fa6b6b5cb4d804b5a39eb249f (diff)
Merge tag '0.4.3' into debian/experimental
Tag leap.common version 0.4.3
Diffstat (limited to 'src/leap/common/events/client.py')
-rw-r--r--src/leap/common/events/client.py13
1 files changed, 5 insertions, 8 deletions
diff --git a/src/leap/common/events/client.py b/src/leap/common/events/client.py
index e085f5b..e38e9d3 100644
--- a/src/leap/common/events/client.py
+++ b/src/leap/common/events/client.py
@@ -465,7 +465,7 @@ class EventsClientThread(threading.Thread, EventsClient):
Make sure the events client thread is started.
"""
with self._lock:
- if flags.EVENTS_ENABLED and not self.is_alive():
+ if not self.is_alive():
self.daemon = True
self.start()
self._initialized.wait()
@@ -508,9 +508,8 @@ def register(event, callback, uid=None, replace=False):
:raises CallbackAlreadyRegisteredError: when there's already a callback
identified by the given uid and replace is False.
"""
- if flags.EVENTS_ENABLED:
- return EventsClientThread.instance().register(
- event, callback, uid=uid, replace=replace)
+ return EventsClientThread.instance().register(
+ event, callback, uid=uid, replace=replace)
def unregister(event, uid=None):
@@ -525,8 +524,7 @@ def unregister(event, uid=None):
:param uid: The callback uid.
:type uid: str
"""
- if flags.EVENTS_ENABLED:
- return EventsClientThread.instance().unregister(event, uid=uid)
+ return EventsClientThread.instance().unregister(event, uid=uid)
def emit(event, *content):
@@ -538,8 +536,7 @@ def emit(event, *content):
:param content: The content of the event.
:type content: list
"""
- if flags.EVENTS_ENABLED:
- return EventsClientThread.instance().emit(event, *content)
+ return EventsClientThread.instance().emit(event, *content)
def instance():