summaryrefslogtreecommitdiffstatshomepage
path: root/tests/basics/async_for2.py
diff options
context:
space:
mode:
authorDamien George <damien.p.george@gmail.com>2016-04-13 15:27:06 +0100
committerDamien George <damien.p.george@gmail.com>2016-04-13 15:27:06 +0100
commitc33df193bfbc09dc5c3b62db6507ad1a79e92ea6 (patch)
tree8085372975f5fe96a850a75aeec2340f31256dc1 /tests/basics/async_for2.py
parenteacbd7aeba3bdd634b56af544e40da87779f4a95 (diff)
downloadmicropython-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.py48
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')