in src/chug/hfds/wrappers.py [0:0]
def __iter__(self):
if isinstance(self.interval_count, SharedCount):
interval_count = self.interval_count.get_value()
else:
interval_count = self.interval_count
self.ds.set_epoch(interval_count)
for sample in self.ds:
yield sample