Merge pull request #87 from ydirson/async-callbacks

Support coroutines as signal handlers (#2)

Author: Tony Crisci

dbus_next/proxy_object.py

@@ -6,11 +6,12 @@
 from .errors import DBusError, InterfaceNotFoundError
 from ._private.util import replace_idx_with_fds
 
-from typing import Type, Union, List
+from typing import Type, Union, List, Coroutine
 import logging
 import xml.etree.ElementTree as ET
 import inspect
 import re
+import asyncio
 
 
 class BaseProxyInterface:
@@ -97,7 +98,9 @@ def _message_handler(self, msg):
 
         body = replace_idx_with_fds(msg.signature, msg.body, msg.unix_fds)
         for handler in self._signal_handlers[msg.member]:
-            handler(*body)
+            cb_result = handler(*body)
+            if isinstance(cb_result, Coroutine):
+                asyncio.create_task(cb_result)
 
     def _add_signal(self, intr_signal, interface):
         def on_signal_fn(fn):