File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -63,7 +63,7 @@ def __init__(
63
63
self .websocket : Optional [WebSocketClientProtocol ] = None
64
64
if subscriptions is None :
65
65
subscriptions = []
66
- self .scheduled_subs = set (subscriptions )
66
+ self .scheduled_subs : Set [ str ] = set (subscriptions )
67
67
self .schedule_resub = True
68
68
69
69
# https://websockets.readthedocs.io/en/stable/reference/client.html#opening-a-connection
@@ -138,6 +138,9 @@ async def connect(
138
138
except ConnectionClosedError :
139
139
logger .debug ("connection closed (ERR)" )
140
140
reconnects += 1
141
+ self .scheduled_subs = set (self .subs )
142
+ self .subs = set ()
143
+ self .schedule_resub = True
141
144
if self .max_reconnects is not None and reconnects > self .max_reconnects :
142
145
return
143
146
continue
You can’t perform that action at this time.
0 commit comments