pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Remove breakpoint in web_bs, 

ensure we only unsub if ws is connected
small_kucoin_fixes
jaredgoldman 2023-03-15 20:26:51 -04:00
parent a3c7bec576
commit b14b323068
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
piker/brokers/kucoin.py
View File

@ -342,15 +342,16 @@ async def stream_quotes(
yield yield
# unsub # unsub
await ws.send_msg( if ws.connected():
{ await ws.send_msg(
"id": connect_id, {
"type": "unsubscribe", "id": connect_id,
"topic": f"/market/ticker:{sym}", "type": "unsubscribe",
"privateChannel": False, "topic": f"/market/ticker:{sym}",
"response": True, "privateChannel": False,
} "response": True,
) }
)
token = await client._get_ws_token() token = await client._get_ws_token()
async with open_autorecon_ws( async with open_autorecon_ws(

1
piker/data/_web_bs.py
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)
) )