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

Fix bug regarding closing websocket connection with .close coroutine method.

Browse Source
This commit is contained in:
Davide Casale
2022-11-23 16:28:05 +01:00
parent 16bbe19634
commit 45a9565cf4
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bfxapi/websocket/BfxWebsocketClient.py
View File

@@ -68,6 +68,7 @@ class BfxWebsocketClient(object):
elif isinstance(message, list) and (chanId := message[0]) == 0 and message[1] != HEARTBEAT: elif isinstance(message, list) and (chanId := message[0]) == 0 and message[1] != HEARTBEAT:
self.handler.handle(message[1], message[2]) self.handler.handle(message[1], message[2])
except websockets.ConnectionClosedError: continue except websockets.ConnectionClosedError: continue
finally: await self.websocket.wait_closed(); break
async def __authenticate(self, API_KEY, API_SECRET, filter=None): async def __authenticate(self, API_KEY, API_SECRET, filter=None):
data = { "event": "auth", "filter": filter, "apiKey": API_KEY } data = { "event": "auth", "filter": filter, "apiKey": API_KEY }
@@ -170,6 +171,7 @@ class _BfxWebsocketBucket(object):
elif isinstance(message, list) and (chanId := message[0]) and message[1] != HEARTBEAT: elif isinstance(message, list) and (chanId := message[0]) and message[1] != HEARTBEAT:
self.handler.handle(self.chanIds[chanId], *message[1:]) self.handler.handle(self.chanIds[chanId], *message[1:])
except websockets.ConnectionClosedError: continue except websockets.ConnectionClosedError: continue
finally: await self.websocket.wait_closed(); break
@_require_websocket_connection @_require_websocket_connection
async def _subscribe(self, channel, subId=None, **kwargs): async def _subscribe(self, channel, subId=None, **kwargs):