Dimitry GroupWork 10648			Aleksey GroupWork 10543
f	1	import asyncio	f	1	import asyncio
	2			2
	3	class Loop:		3	class Loop:
n	4	_funcs = []	n	4	funcs = []
	5	_steps = []		5	wrappers = []
	6	_evt = None		6	ready = None
	7	_launched = False		7	started = False
	8	_halt = False		8	stop = False
	9	_count = 0		9	total = 0
	10			10
n	11	def __call__(self, fn):	n	11	def __call__(self, func):
	12	Loop._funcs.append(fn)		12	Loop.funcs.append(func)
	13	Loop._count = len(Loop._funcs)		13	Loop.total = len(Loop.funcs)
	14			14
n	15	async def outer(*a, **kw):	n	15	async def wrapper(*args, **kwargs):
	16	if Loop._evt is None:		16	if Loop.ready is None:
	17	Loop._evt = asyncio.Event()		17	Loop.ready = asyncio.Event()
	18			18
n	19	async def runner():	n	19	async def step():
	20	while True:		20	while True:
n	21	if Loop._halt:	n	21	if Loop.stop:
	22	return None		22	return None
n	23	out = await fn(*a, **kw)	n	23	r = await func(*args, **kwargs)
	24	if out is None:		24	if r is None:
	25	Loop._halt = True		25	Loop.stop = True
	26	return None		26	return None
n	27	return out	n	27	return r
	28	Loop._steps.append(runner)		28	Loop.wrappers.append(step)
	29	if len(Loop._steps) == Loop._count:		29	if len(Loop.wrappers) == Loop.total:
	30	Loop._evt.set()		30	Loop.ready.set()
	31	await Loop._evt.wait()		31	await Loop.ready.wait()
	32	if not Loop._launched:		32	if not Loop.started:
	33	Loop._launched = True		33	Loop.started = True
	34	await Loop._cycle()		34	await Loop._run()
	35	return None		35	return None
n	36	return outer	n	36	return wrapper
	37			37
	38	@staticmethod		38	@staticmethod
n	39	async def _cycle():	n	39	async def _run():
	40	seq = Loop._steps		40	steps = Loop.wrappers
	41	while True:		41	while True:
t	42	for r in seq:	t	42	for s in steps:
	43	val = await r()		43	r = await s()
	44	if val is None:		44	if r is None:
	45	return		45	return

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