diff --git a/tasks/stirrer.py b/tasks/stirrer.py index 33eecc0..5d6aafd 100644 --- a/tasks/stirrer.py +++ b/tasks/stirrer.py @@ -2,6 +2,7 @@ import asyncio from tasks import ATask from ws.message import MsgIo from components import AStirrer +from utils.value import ChangedInteger class StirrerTask(ATask): @@ -20,6 +21,9 @@ class StirrerTask(ATask): def on_cycletime_changed(self, value): asyncio.create_task(self.send({'CycleTime': value})) + def on_changed_active(self, is_activated): + asyncio.create_task(self.send({'Activate': int(is_activated)})) + async def recv(self, data): print(data) @@ -31,6 +35,9 @@ class StirrerTask(ATask): self.device.set_on_changed("speed", self.on_speed_changed) self.device.set_on_changed("dutyCycle", self.on_dutycycle_changed) self.device.set_on_changed("cycleTime", self.on_cycletime_changed) + self.device.set_on_changed("cycleTime", self.on_cycletime_changed) + self.device.set_on_changed('is_active', ChangedInteger(self.on_changed_active).set) + while True: self.device.process() await asyncio.sleep(self.interval)