Merge pull request #12 from wlatanowicz/wl/async-client

Allow coroutines as client event callbacks
wlatanowicz · Mar 23, 2023 · 5521f01 · 5521f01
2 parents 1b0ad22 + 32b5c1e
commit 5521f01
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/docker-examples/client/simple_events/client.py b/docker-examples/client/simple_events/client.py
@@ -44,7 +44,7 @@ async def main_loop():
     control_connection = TCP(host, port)
     blob_connection = TCP(host, port)
 
-    def client_callback(event):
+    async def client_callback(event):
         print(event)
 
     client = Client(control_connection, blob_connection)

diff --git a/indi/client/client.py b/indi/client/client.py
@@ -302,7 +302,10 @@ def trigger_event(self, event: events.BaseEvent):
         for callback in self.callbacks:
             if callback.accepts_event(event):
                 try:
-                    callback.callback(event)
+                    if asyncio.iscoroutinefunction(callback.callback):
+                        asyncio.get_running_loop().create_task(callback.callback(event))
+                    else:
+                        callback.callback(event)
                 except:
                     logger.exception("Error in event handler")