Ensure quick port value changes are properly processed

Author: ccrisan

qtoggleserver/zigbee2mqtt/client.py

@@ -10,6 +10,7 @@
 
 import aiomqtt
 
+from qtoggleserver.core import main
 from qtoggleserver.core import ports as core_ports
 from qtoggleserver.core.typing import GenericJSONDict, GenericJSONList
 from qtoggleserver.peripherals import Peripheral
@@ -366,6 +367,9 @@ async def handle_device_state_message(self, friendly_name: str, payload_json: Ge
 
         await self._maybe_trigger_port_update(friendly_name, old_state, state)
 
+        # Ensure each port value change is processed asap
+        await main.update()
+
     async def do_request(self, subtopic: str, payload_json: GenericJSONDict) -> tuple[str, GenericJSONDict]:
         if not self._mqtt_client:
             raise ClientNotConnected()