From b02bfe02f265c9a17f3ae77d86c8f02f42adf758 Mon Sep 17 00:00:00 2001 From: Victor Stinner Date: Fri, 21 Nov 2014 03:27:22 +0100 Subject: Port tests to asyncio 3.4.1 --- tests/test_eventlet.py | 32 ++++++++++++++++++-------------- 1 file changed, 18 insertions(+), 14 deletions(-) diff --git a/tests/test_eventlet.py b/tests/test_eventlet.py index 4d5f019..eb428d7 100644 --- a/tests/test_eventlet.py +++ b/tests/test_eventlet.py @@ -138,23 +138,27 @@ def wait_task(task): return event.wait() def greenthread_chain_coro(result, loop): - t1 = loop.create_task(coro_slow_append(result, 1, 0.2)) - value = wait_task(t1) - result.append(value) + try: + t1 = asyncio.async(coro_slow_append(result, 1, 0.2), loop=loop) + value = wait_task(t1) + result.append(value) - t2 = loop.create_task(coro_slow_append(result, 2, 0.1)) - value = wait_task(t2) - result.append(value) + t2 = asyncio.async(coro_slow_append(result, 2, 0.1), loop=loop) + value = wait_task(t2) + result.append(value) - t3 = loop.create_task(coro_slow_error(0.001)) - try: - value = wait_task(t3) - except ValueError as exc: - result.append(str(exc)) + t3 = asyncio.async(coro_slow_error(0.001), loop=loop) + try: + value = wait_task(t3) + except ValueError as exc: + result.append(str(exc)) - result.append(4) - loop.call_soon(loop.stop) - return result + result.append(4) + return result + except Exception as exc: + result.append(repr(exc)) + finally: + loop.call_soon(loop.stop) class EventletTests(tests.TestCase): -- cgit v1.2.1