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__(
6363 self .websocket : Optional [WebSocketClientProtocol ] = None
6464 if subscriptions is None :
6565 subscriptions = []
66- self .scheduled_subs = set (subscriptions )
66+ self .scheduled_subs : Set [ str ] = set (subscriptions )
6767 self .schedule_resub = True
6868
6969 # https://websockets.readthedocs.io/en/stable/reference/client.html#opening-a-connection
@@ -138,6 +138,9 @@ async def connect(
138138 except ConnectionClosedError :
139139 logger .debug ("connection closed (ERR)" )
140140 reconnects += 1
141+ self .scheduled_subs = set (self .subs )
142+ self .subs = set ()
143+ self .schedule_resub = True
141144 if self .max_reconnects is not None and reconnects > self .max_reconnects :
142145 return
143146 continue
You can’t perform that action at this time.
0 commit comments