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

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