Remove breakpoint in web_bs,

ensure we only unsub if ws is connected
emit_clear_ticks_only_on_ts_change
jaredgoldman 2023-03-15 20:26:51 -04:00
parent 2d3c351ca4
commit afa68d2d59
2 changed files with 10 additions and 10 deletions

View File

@ -342,6 +342,7 @@ async def stream_quotes(
yield yield
# unsub # unsub
if ws.connected():
await ws.send_msg( await ws.send_msg(
{ {
"id": connect_id, "id": connect_id,

View File

@ -100,7 +100,6 @@ class NoBsWs:
last_err = None last_err = None
for i in range(tries): for i in range(tries):
try: try:
breakpoint()
self._ws = await self._stack.enter_async_context( self._ws = await self._stack.enter_async_context(
trio_websocket.open_websocket_url(self.url) trio_websocket.open_websocket_url(self.url)
) )