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

`binance`: same thing, only unsub when connected

misc_brokerd_backend_repairs
Tyler Goodlet 2023-01-19 10:35:39 -05:00
parent b89fd9652c
commit afc45a8e16
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
piker/brokers/binance.py
View File

@ -519,14 +519,15 @@ async def stream_quotes(
subs.append("{sym}@bookTicker") subs.append("{sym}@bookTicker")
# unsub from all pairs on teardown # unsub from all pairs on teardown
await ws.send_msg({ if ws.connected():
"method": "UNSUBSCRIBE", await ws.send_msg({
"params": subs, "method": "UNSUBSCRIBE",
"id": uid, "params": subs,
}) "id": uid,
})
# XXX: do we need to ack the unsub? # XXX: do we need to ack the unsub?
# await ws.recv_msg() # await ws.recv_msg()
async with open_autorecon_ws( async with open_autorecon_ws(
'wss://stream.binance.com/ws', 'wss://stream.binance.com/ws',