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

Use `open_sample_stream()` in display loop

multichartz
Tyler Goodlet 2023-01-04 23:15:45 -05:00
parent 7208b3a2d2
commit 73f1e362bc
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
piker/ui/_display.py
View File

@ -41,7 +41,10 @@ from ..data.types import Struct
from ..data._sharedmem import ( from ..data._sharedmem import (
ShmArray, ShmArray,
) )
from ..data._sampling import _tick_groups from ..data._sampling import (
_tick_groups,
open_sample_stream,
)
from ._axes import YAxisLabel from ._axes import YAxisLabel
from ._chart import ( from ._chart import (
ChartPlotWidget, ChartPlotWidget,
@ -188,7 +191,7 @@ async def increment_history_view(
# wakeups/ctx switches verus logic checks (as normal) # wakeups/ctx switches verus logic checks (as normal)
# - we need increment logic that only does the view shift # - we need increment logic that only does the view shift
# call when the uppx permits/needs it # call when the uppx permits/needs it
async with hist_viz.flume.index_stream(int(1)) as istream: async with open_sample_stream(1.) as istream:
async for msg in istream: async for msg in istream:
# l3 = ds.viz.shm.array[-3:] # l3 = ds.viz.shm.array[-3:]