Хайруллина Алина GroupWork 11002			action22k GroupWork 10465
f	1	import asyncio	f	1	import asyncio
	2			2
	3	class Loop:		3	class Loop:
n	4	_tasks = []	n	4	_registry = []
	5	_pointer = 0		5	_current = 0
	6	_halted = False		6	_finished = False
	7			7
	8	def __init__(self):		8	def __init__(self):
	9	pass		9	pass
	10			10
n	11	def __call__(self, routine):	n	11	def __call__(self, coro):
	12	slot = len(Loop._tasks)		12	index = len(Loop._registry)
	13	Loop._tasks.append(None)		13	Loop._registry.append(None)
	14			14
n	15	async def envelope(*a, **kw):	n	15	async def wrapper(*args, **kwargs):
	16	while True:		16	while True:
n	17	if Loop._halted:	n	17	if Loop._finished:
	18	return None		18	return None
n	19	if Loop._pointer != slot:	n	19	if Loop._current != index:
	20	await asyncio.sleep(0)		20	await asyncio.sleep(0)
	21	continue		21	continue
n	22	outcome = await routine(*a, **kw)	n	22	res = await coro(*args, **kwargs)
	23	if outcome is None:		23	if res is None:
	24	Loop._halted = True		24	Loop._finished = True
	25	Loop._pointer = (Loop._pointer + 1) % len(Loop._tasks)		25	Loop._current = (Loop._current + 1) % len(Loop._registry
				>	)
	26	if outcome is None:		26	if res is None:
	27	return None		27	return None
t	28	return envelope	t	28	return wrapper

Legends
Colors  Added  Changed Deleted	Links (f)irst change (n)ext change (t)op