use async instead of create_task for 3.4 compatibility

2d558b54 · Olivier R-D · fa813095 · 2d558b54
Commit 2d558b54 authored Apr 30, 2015 by Olivier R-D
Show whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

opcua/utils.py opcua/utils.py +2 -1

No files found.
--- a/opcua/utils.py
+++ b/opcua/utils.py
@@ -140,7 +140,8 @@ class ThreadLoop(threading.Thread):
        self.loop.call_soon_threadsafe(p)

    def _create_task(self, future, coro, cb=None):
-        task = self.loop.create_task(coro)
+        #task = self.loop.create_task(coro)
+        task = asyncio.async(coro, loop=self.loop) 
        if cb:
            task.add_done_callback(cb)
        future.set_result(task)