From 26f25e5848d3ba5b351677e5bd8dc9fff464d684 Mon Sep 17 00:00:00 2001 From: Davide Casale Date: Fri, 28 Jul 2023 16:41:52 +0200 Subject: [PATCH] Fix bug in method BfxWebSocketBucket::unsubscribe. --- bfxapi/websocket/_client/bfx_websocket_bucket.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/bfxapi/websocket/_client/bfx_websocket_bucket.py b/bfxapi/websocket/_client/bfx_websocket_bucket.py index 07c5034..c62a436 100644 --- a/bfxapi/websocket/_client/bfx_websocket_bucket.py +++ b/bfxapi/websocket/_client/bfx_websocket_bucket.py @@ -113,12 +113,11 @@ class BfxWebSocketBucket(Connection): @Connection.require_websocket_connection async def unsubscribe(self, sub_id: str) -> None: - for subscription in self.__subscriptions.values(): + for chan_id, subscription in self.__subscriptions.items(): if subscription["subId"] == sub_id: - data = { "event": "unsubscribe", \ - "chanId": subscription["subId"] } - - message = json.dumps(data) + message = json.dumps({ + "event": "unsubscribe", + "chanId": chan_id }) await self._websocket.send(message)