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

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