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

WIP idea: drain feed stream, doesn't do much..

vlm_plotz
Tyler Goodlet 2021-12-09 08:21:35 -05:00
parent c7436d5857
commit 719187bf5a
1 changed files with 19 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
piker/ui/_display.py
View File

@ -182,29 +182,28 @@ async def update_linked_charts_graphics(
view = chart.view
last_quote = time.time()
# async def iter_drain_quotes():
# # NOTE: all code below this loop is expected to be synchronous
# # and thus draw instructions are not picked up jntil the next
# # wait / iteration.
# async for quotes in stream:
# while True:
# try:
# moar = stream.receive_nowait()
# except trio.WouldBlock:
# yield quotes
# break
# else:
# for sym, quote in moar.items():
# ticks_frame = quote.get('ticks')
# if ticks_frame:
# quotes[sym].setdefault(
# 'ticks', []).extend(ticks_frame)
# print('pulled extra')
async def iter_drain_quotes():
# NOTE: all code below this loop is expected to be synchronous
# and thus draw instructions are not picked up jntil the next
# wait / iteration.
async for quotes in stream:
while True:
try:
moar = stream.receive_nowait()
except trio.WouldBlock:
yield quotes
break
else:
for sym, quote in moar.items():
ticks_frame = quote.get('ticks')
if ticks_frame:
quotes[sym].setdefault(
'ticks', []).extend(ticks_frame)
print('pulled extra')
# yield quotes
yield quotes
# async for quotes in iter_drain_quotes():
async for quotes in stream:
quote_period = time.time() - last_quote