fixup! WIP: support async coroutine functions

circuits/core/handlers.py

@@ -1,6 +1,7 @@
 """
 This module define the @handler decorator/function and the HandlesType type.
 """
+import inspect
 from collections.abc import Callable
 
 from circuits.tools import getargspec
@@ -63,6 +64,7 @@ def handler(*names, **kwargs):
     """
 
     def wrapper(f):
+        assert inspect.iscoroutinefunction(f)
         if names and isinstance(names[0], bool) and not names[0]:
             f.handler = False
             return f

circuits/core/workers.py

@@ -82,5 +82,6 @@ async def _on_stopped(self, event, *args):
     @handler("task")
     async def _on_task(self, f, *args, **kwargs):
         result = self.pool.apply_async(f, args, kwargs)
-        await result.ready()
+        while not result.ready():
+            await
         return result.get()