pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

Facepalm**2: only update on special "update" msg

mkts_backup
Tyler Goodlet 2022-03-07 07:20:58 -05:00
parent 49531a2da6
commit 3dc87e0426
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piker/fsp/_engine.py
View File

@ -211,7 +211,7 @@ async def fsp_compute(
# always trigger UI refresh after history update, # always trigger UI refresh after history update,
# see ``piker.ui._fsp.FspAdmin.open_chain()`` and # see ``piker.ui._fsp.FspAdmin.open_chain()`` and
# ``piker.ui._display.trigger_update()``. # ``piker.ui._display.trigger_update()``.
await stream.send(index) await stream.send('update')
async for processed in out_stream: async for processed in out_stream:

6
piker/ui/_fsp.py
View File

@ -50,6 +50,7 @@ from ._forms import (
mk_form, mk_form,
open_form_input_handling, open_form_input_handling,
) )
from . import _display
from ..fsp._api import maybe_mk_fsp_shm, Fsp from ..fsp._api import maybe_mk_fsp_shm, Fsp
from ..fsp import cascade from ..fsp import cascade
from ..fsp._volume import ( from ..fsp._volume import (
@ -438,12 +439,11 @@ class FspAdmin:
started.set() started.set()
from ._display import trigger_update
# wait for graceful shutdown signal # wait for graceful shutdown signal
async with stream.subscribe() as stream: async with stream.subscribe() as stream:
async for msg in stream: async for msg in stream:
trigger_update() if msg == 'update':
_display.trigger_update(self.linked)
await complete.wait() await complete.wait()