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

TOSQUASH, fix separate vlm vs trade rate

windows_fixes_yo
Tyler Goodlet 2022-02-02 08:07:29 -05:00
parent f3289c1977
commit 97c2f86092
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
piker/fsp/_volume.py
View File

@ -193,7 +193,7 @@ async def dolla_vlm(
'1m_trade_rate', '1m_trade_rate',
'1m_vlm_rate', '1m_vlm_rate',
), ),
curve_style='step', curve_style='line',
) )
async def flow_rates( async def flow_rates(
source: AsyncReceiver[dict], source: AsyncReceiver[dict],
@ -213,14 +213,14 @@ async def flow_rates(
async for quote in source: async for quote in source:
if quote: if quote:
tr = quote['tradeRate'], tr = quote['tradeRate']
if tr != ltr: if tr != ltr:
print(f'trade rate: {tr}') print(f'trade rate: {tr}')
yield '1m_trade_rate', tr yield '1m_trade_rate', tr
ltr = tr ltr = tr
vr = quote['volumeRate'], vr = quote['volumeRate']
if vr != lvr: if vr != lvr:
print(f'vlm rate: {tr}') print(f'vlm rate: {vr}')
yield '1m_vlm_rate', tr yield '1m_vlm_rate', vr
ltr = tr lvr = vr