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 70c4ddd commit 3b1e194Copy full SHA for 3b1e194
1 file changed
polygon/websocket/__init__.py
@@ -63,7 +63,7 @@ def __init__(
63
self.websocket: Optional[WebSocketClientProtocol] = None
64
if subscriptions is None:
65
subscriptions = []
66
- self.scheduled_subs = set(subscriptions)
+ self.scheduled_subs: Set[str] = set(subscriptions)
67
self.schedule_resub = True
68
69
# https://websockets.readthedocs.io/en/stable/reference/client.html#opening-a-connection
@@ -138,6 +138,9 @@ async def connect(
138
except ConnectionClosedError:
139
logger.debug("connection closed (ERR)")
140
reconnects += 1
141
+ self.scheduled_subs = set(self.subs)
142
+ self.subs = set()
143
+ self.schedule_resub = True
144
if self.max_reconnects is not None and reconnects > self.max_reconnects:
145
return
146
continue
0 commit comments