We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9114e2c commit 97bad7fCopy full SHA for 97bad7f
bfxapi/websocket/_client/bfx_websocket_bucket.py
@@ -67,8 +67,9 @@ async def start(self) -> None:
67
68
if isinstance(message, list):
69
if (chan_id := cast(int, message[0])) and \
70
- (message[1] != Connection._HEARTBEAT):
71
- self.__handler.handle(self.__subscriptions[chan_id], message[1:])
+ (subscription := self.__subscriptions.get(chan_id)) and \
+ (message[1] != Connection._HEARTBEAT):
72
+ self.__handler.handle(subscription, message[1:])
73
74
def __on_subscribed(self, message: Dict[str, Any]) -> None:
75
chan_id = cast(int, message["chan_id"])
0 commit comments