action22k GroupWork 10465			Долгих Данила GroupWork 10625
f	1	import asyncio	f	1	import asyncio
	2			2
	3	class Loop:		3	class Loop:
n	4	_registry = []	n	4	_coroutines = []
	5	_current = 0		5	_step_idx = 0
	6	_finished = False		6	_stop_flag = False
	7			7
	8	def __init__(self):		8	def __init__(self):
	9	pass		9	pass
	10			10
n	11	def __call__(self, coro):	n	11	def __call__(self, coro_func):
	12	index = len(Loop._registry)		12	idx = len(Loop._coroutines)
	13	Loop._registry.append(None)		13	Loop._coroutines.append(None)
	14			14
n	15	async def wrapper(*args, **kwargs):	n	15	async def wrapped(*args, **kwargs):
	16	while True:		16	while True:
n	17	if Loop._finished:	n	17	if Loop._stop_flag:
	18	return None		18	return None
n	19	if Loop._current != index:	n	19	if Loop._step_idx != idx:
	20	await asyncio.sleep(0)		20	await asyncio.sleep(0)
	21	continue		21	continue
n	22	res = await coro(*args, **kwargs)	n	22	result = await coro_func(*args, **kwargs)
	23	if res is None:		23	if result is None:
	24	Loop._finished = True		24	Loop._stop_flag = True
	25	Loop._current = (Loop._current + 1) % len(Loop._registry		25	Loop._step_idx = (Loop._step_idx + 1) % len(Loop._corout
	>	)		>	ines)
	26	if res is None:		26	if result is None:
	27	return None		27	return None
t	28	return wrapper	t	28	return wrapped

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