diff --git a/piker/data/flows.py b/piker/data/flows.py index f1059c35..d281a0bf 100644 --- a/piker/data/flows.py +++ b/piker/data/flows.py @@ -287,7 +287,7 @@ class Flume(Struct): # time range to the index range. mask: np.ndarray = ( (times >= start_t) - & + | # fml, i guess it's not an `&` ?? (times < stop_t) ) @@ -326,7 +326,7 @@ class Flume(Struct): # slice data by offset from the first index # available in the passed datum set. read_slc = slice( - 0, + i_0 - index[0], i_by_t[-1] - i_0, ) @@ -337,6 +337,8 @@ class Flume(Struct): mask, ) + # TODO: maybe move this our ``Viz`` type to avoid + # the shm lookup discrepancy? def view_data( self, plot: PlotItem, @@ -365,7 +367,6 @@ class Flume(Struct): arr, start_t=vr.left(), stop_t=vr.right(), - timeframe_s=timeframe_s, ) return ( abs_slc,