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

Remove breakpoint in binance

small_kucoin_fixes
jaredgoldman 2023-04-12 20:43:28 -04:00
parent ff0f8dfaca
commit 2c82b2aba9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
piker/brokers/binance.py
View File

@ -343,7 +343,7 @@ async def stream_messages(
# https://binance-docs.github.io/apidocs/spot/en/#individual-symbol-book-ticker-streams # https://binance-docs.github.io/apidocs/spot/en/#individual-symbol-book-ticker-streams
if msg.get('u'): if msg.get('u'):
sym = msg['s'] sym = msg['s']what does the trio_async_generator from trio_util do?
bid = float(msg['b']) bid = float(msg['b'])
bsize = float(msg['B']) bsize = float(msg['B'])
ask = float(msg['a']) ask = float(msg['a'])
@ -485,7 +485,7 @@ async def stream_quotes(
si['asset_type'] = 'crypto' si['asset_type'] = 'crypto'
symbol = symbols[0] symbol = symbols[0]
breakpoint()
init_msgs = { init_msgs = {
# pass back token, and bool, signalling if we're the writer # pass back token, and bool, signalling if we're the writer
# and that history has been written # and that history has been written