Aleksey TwoWay 10546			Dimitry TwoWay 10650
f	1	import asyncio	f	1	import asyncio
	2			2
	3	class Portal(asyncio.Barrier):		3	class Portal(asyncio.Barrier):
	4			4
n	5	def __init__(self, parties):	n	5	def __init__(self, count):
	6	super().__init__(parties)		6	super().__init__(count)
	7	self.topic = None		7	self.topic = None
n	8	self._proposed_topic = None	n	8	self._tmp = None
	9	self._out_barrier = asyncio.Barrier(parties)		9	self._sync = asyncio.Barrier(count)
	10			10
n	11	async def wait(self, topic=None):	n	11	async def wait(self, t=None):
	12	if topic is not None:		12	if t is not None:
	13	self._proposed_topic = topic		13	self._tmp = t
	14	idx = await super().wait()		14	pos = await super().wait()
	15	if idx == 0:		15	if pos == 0:
	16	self.topic = self._proposed_topic		16	self.topic = self._tmp
	17	await self._out_barrier.wait()		17	await self._sync.wait()
	18	return idx		18	return pos
	19			19
	20	async def reset(self):		20	async def reset(self):
	21	self.topic = None		21	self.topic = None
n	22	self._proposed_topic = None	n	22	self._tmp = None
	23	await super().reset()		23	await super().reset()
t	24	await self._out_barrier.reset()	t	24	await self._sync.reset()

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