File py311.patch of Package python-aioeventlet

Overview Repositories Revisions Requests Users Attributes Meta

File py311.patch of Package python-aioeventlet

Index: aioeventlet-0.5.1/tests/test_eventlet.py
===================================================================
--- aioeventlet-0.5.1.orig/tests/test_eventlet.py
+++ aioeventlet-0.5.1/tests/test_eventlet.py
@@ -19,72 +19,78 @@ try:
     import asyncio
 
     exec('''if 1:
-        @asyncio.coroutine
-        def coro_wrap_greenthread():
+        async def coro_wrap_greenthread():
             result = []
 
             gt = eventlet.spawn(eventlet_slow_append, result, 1, 0.020)
-            value = yield from aioeventlet.wrap_greenthread(gt)
+            for i in aioeventlet.wrap_greenthread(gt):
+                value = yield i
             result.append(value)
 
             gt = eventlet.spawn(eventlet_slow_append, result, 2, 0.010)
-            value = yield from aioeventlet.wrap_greenthread(gt)
+            for i in aioeventlet.wrap_greenthread(gt):
+                value = yield i
             result.append(value)
 
             gt = eventlet.spawn(eventlet_slow_error)
             try:
-                yield from aioeventlet.wrap_greenthread(gt)
+                for i in aioeventlet.wrap_greenthread(gt):
+                    yield i
             except ValueError as exc:
                 result.append(str(exc))
 
             result.append(4)
-            return result
+            yield result
+            return
 
-        @asyncio.coroutine
-        def coro_slow_append(result, value, delay=SHORT_SLEEP):
-            yield from asyncio.sleep(delay)
+        async def coro_slow_append(result, value, delay=SHORT_SLEEP):
+            for i in asyncio.sleep(delay):
+                yield i
             result.append(value)
-            return value * 10
+            yield value * 10
+            return
 
-        @asyncio.coroutine
-        def coro_slow_error():
-            yield from asyncio.sleep(0.001)
+        async def coro_slow_error():
+            for i in asyncio.sleep(0.001):
+                yield i
             raise ValueError("error")
     ''')
 except ImportError:
     import trollius as asyncio
     from trollius import From, Return
 
-    @asyncio.coroutine
-    def coro_wrap_greenthread():
+    async def coro_wrap_greenthread():
         result = []
 
         gt = eventlet.spawn(eventlet_slow_append, result, 1, 0.020)
-        value = yield From(aioeventlet.wrap_greenthread(gt))
+        for i in From(aioeventlet.wrap_greenthread(gt)):
+            value = yield i
         result.append(value)
 
         gt = eventlet.spawn(eventlet_slow_append, result, 2, 0.010)
-        value = yield From(aioeventlet.wrap_greenthread(gt))
+        for i in From(aioeventlet.wrap_greenthread(gt)):
+            value = yield i
         result.append(value)
 
         gt = eventlet.spawn(eventlet_slow_error)
         try:
-            yield From(aioeventlet.wrap_greenthread(gt))
+            for i in From(aioeventlet.wrap_greenthread(gt)):
+                yield i
         except ValueError as exc:
             result.append(str(exc))
 
         result.append(4)
         raise Return(result)
 
-    @asyncio.coroutine
-    def coro_slow_append(result, value, delay=SHORT_SLEEP):
-        yield From(asyncio.sleep(delay))
+    async def coro_slow_append(result, value, delay=SHORT_SLEEP):
+        for i in From(asyncio.sleep(delay)):
+            yield i
         result.append(value)
         raise Return(value * 10)
 
-    @asyncio.coroutine
-    def coro_slow_error():
-        yield From(asyncio.sleep(0.001))
+    async def coro_slow_error():
+        for i in From(asyncio.sleep(0.001)):
+            yield i
         raise ValueError("error")
 
 
@@ -223,8 +229,7 @@ class LinkFutureTests(tests.TestCase):
         def func(obj):
             return aioeventlet.yield_future(obj)
 
-        @asyncio.coroutine
-        def coro_func():
+        async def coro_func():
             print("do something")
 
         def regular_func():
@@ -315,8 +320,7 @@ class WrapGreenthreadTests(tests.TestCas
             pass
         self.assertRaises(TypeError, aioeventlet.wrap_greenthread, func)
 
-        @asyncio.coroutine
-        def coro_func():
+        async def coro_func():
             pass
         coro_obj = coro_func()
         self.addCleanup(coro_obj.close)

Places

File py311.patch of Package python-aioeventlet

Places