FilesExpand file tree

 encoding

/

async_for2.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

48 lines (41 loc) · 1.02 KB

 encoding

/

async_for2.py

Copy path

Top

File metadata and controls

• Code
• Blame

48 lines (41 loc) · 1.02 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

# test waiting within "async for" aiter/anext functions

import sys

if sys.implementation.name in ('micropython', 'circuitpython'):

# 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')