Use `open_sample_stream()` in display loop
parent
63f0567418
commit
02c3ea1743
piker/ui
|
@ -43,7 +43,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,
|
||||||
|
@ -194,7 +197,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:]
|
||||||
|
|
Loading…
Reference in New Issue