From 87d394ca170e286ed1a66c00921af4a34103cbfd Mon Sep 17 00:00:00 2001 From: jens Date: Thu, 17 Dec 2020 16:35:30 +0100 Subject: [PATCH] - added listener for 'activate' --- tasks/stirrer.py | 7 +++++++ 1 file changed, 7 insertions(+) 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)