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

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