aljaz/bitfinex-api-py
1
0
Fork 0
mirror of https://github.com/aljazceru/bitfinex-api-py.git synced 2025-12-19 14:54:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Allow users to use .on and .once as non-decorators methods.

Browse Source
This commit is contained in:
Davide Casale
2022-11-28 16:58:09 +01:00
parent 9e8bea905a
commit 4bb62a942f
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
bfxapi/websocket/BfxWebsocketClient.py
View File

@@ -125,22 +125,26 @@ class BfxWebsocketClient(object):
if all(bucket.websocket != None and bucket.websocket.open == True for bucket in self.buckets): if all(bucket.websocket != None and bucket.websocket.open == True for bucket in self.buckets):
self.event_emitter.emit("open") self.event_emitter.emit("open")
def on(self, event): def on(self, event, callback = None):
if event not in BfxWebsocketClient.EVENTS: if event not in BfxWebsocketClient.EVENTS:
raise EventNotSupported(f"Event <{event}> is not supported. To get a list of available events print BfxWebsocketClient.EVENTS") raise EventNotSupported(f"Event <{event}> is not supported. To get a list of available events print BfxWebsocketClient.EVENTS")
if callback != None:
return self.event_emitter.on(event, callback)
def handler(function): def handler(function):
self.event_emitter.on(event, function) self.event_emitter.on(event, function)
return handler return handler
def once(self, event): def once(self, event, callback = None):
if event not in BfxWebsocketClient.EVENTS: if event not in BfxWebsocketClient.EVENTS:
raise EventNotSupported(f"Event <{event}> is not supported. To get a list of available events print BfxWebsocketClient.EVENTS") raise EventNotSupported(f"Event <{event}> is not supported. To get a list of available events print BfxWebsocketClient.EVENTS")
if callback != None:
return self.event_emitter.once(event, callback)
def handler(function): def handler(function):
self.event_emitter.once(event, function) self.event_emitter.once(event, function)
return handler return handler
class _BfxWebsocketBucket(object): class _BfxWebsocketBucket(object):