queue = []
last = 0
- # Methods
+ # Constructor
def __init__(self, config):
self.config = config
stream.datapoints = points
return stream
+ if not self.running() or len(self.queue) == 0:
+ return
+
self.feed.datastreams = [
get(self.queue, 'acc'),
get(self.queue, 'mag'),