diff options
author | Damien George <damien.p.george@gmail.com> | 2016-04-13 15:27:06 +0100 |
---|---|---|
committer | Damien George <damien.p.george@gmail.com> | 2016-04-13 15:27:06 +0100 |
commit | c33df193bfbc09dc5c3b62db6507ad1a79e92ea6 (patch) | |
tree | 8085372975f5fe96a850a75aeec2340f31256dc1 /tests/basics/async_for2.py | |
parent | eacbd7aeba3bdd634b56af544e40da87779f4a95 (diff) | |
download | micropython-c33df193bfbc09dc5c3b62db6507ad1a79e92ea6.tar.gz micropython-c33df193bfbc09dc5c3b62db6507ad1a79e92ea6.zip |
tests: Add 6 tests for async await/for/with.
Diffstat (limited to 'tests/basics/async_for2.py')
-rw-r--r-- | tests/basics/async_for2.py | 48 |
1 files changed, 48 insertions, 0 deletions
diff --git a/tests/basics/async_for2.py b/tests/basics/async_for2.py new file mode 100644 index 0000000000..89584fcb10 --- /dev/null +++ b/tests/basics/async_for2.py @@ -0,0 +1,48 @@ +# test waiting within "async for" aiter/anext functions + +import sys +if sys.implementation.name == 'micropython': + # uPy allows normal generators to be awaitables + coroutine = lambda f: f +else: + import types + coroutine = types.coroutine + +@coroutine +def f(x): + print('f start:', x) + yield x + 1 + yield x + 2 + return x + 3 + +class ARange: + def __init__(self, high): + print('init') + self.cur = 0 + self.high = high + + async def __aiter__(self): + print('aiter') + print('f returned:', await f(10)) + return self + + async def __anext__(self): + print('anext') + print('f returned:', await f(20)) + if self.cur < self.high: + val = self.cur + self.cur += 1 + return val + else: + raise StopAsyncIteration + +async def coro(): + async for x in ARange(4): + print('x', x) + +o = coro() +try: + while True: + print('coro yielded:', o.send(None)) +except StopIteration: + print('finished') |