From 611486627f8dfc82841ff2d17ed13ebeed09622e Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sat, 9 Jan 2021 10:55:00 -0500 Subject: [PATCH] Cleaning --- piker/data/_buffer.py | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/piker/data/_buffer.py b/piker/data/_buffer.py index 9a496e7a..896b503b 100644 --- a/piker/data/_buffer.py +++ b/piker/data/_buffer.py @@ -65,14 +65,6 @@ async def increment_ohlc_buffer( # adjust delay to compensate for trio processing time ad = min(_shms.keys()) - 0.001 - # async def sleep(): - # """Sleep until next time frames worth has passed from last bar. - # """ - # # last_ts = shm.array[-1]['time'] - # # delay = max((last_ts + ad) - time.time(), 0) - # # await trio.sleep(delay) - # await trio.sleep(ad) - total_s = 0 # total seconds counted lowest = min(_shms.keys()) ad = lowest - 0.001 @@ -83,9 +75,6 @@ async def increment_ohlc_buffer( await trio.sleep(ad) total_s += lowest - # # sleep for duration of current bar - # await sleep() - # increment all subscribed shm arrays # TODO: this in ``numba`` for delay_s, shms in _shms.items():