Демихов Валентин, 611 группа FilterQueue 17683			Каплан Владимир Сергеевич 611 ВМК FilterQueue 18234
f	1	import asyncio	f	1	import asyncio
	2			2
	3	class FilterQueue(asyncio.Queue):		3	class FilterQueue(asyncio.Queue):
	4			4
n	5	def __init__(self, *args, **kwargs):	n	5	def __init__(self, *a, **b):
	6	super().__init__(*args, **kwargs)		6	super().__init__(*a, **b)
	7	self.window = None		7	self.window = None
	8			8
n	9	def _put(self, item):	n	9	def _put(self, y):
	10	self._queue.append(item)		10	self._queue.append(y)
	11	if self.window is None:		11	if self.window is None:
n	12	self.window = item	n	12	self.window = y
	13			13
n	14	def __contains__(self, checker):	n	14	def __contains__(self, c):
	15	for item in self._queue:		15	for d in self._queue:
	16	if checker(item):		16	if c(d):
	17	return True		17	return True
	18	return False		18	return False
	19			19
	20	def _get(self):		20	def _get(self):
n	21	item = self._queue.popleft()	n	21	e = self._queue.popleft()
	22	if self._queue:		22	if self._queue:
	23	self.window = self._queue[0]		23	self.window = self._queue[0]
	24	else:		24	else:
	25	self.window = None		25	self.window = None
n	26	return item	n	26	return e
	27			27
	28	def later(self):		28	def later(self):
	29	if not self._queue:		29	if not self._queue:
	30	self.window = None		30	self.window = None
	31	raise asyncio.QueueEmpty		31	raise asyncio.QueueEmpty
n	32	item = self._get()	n	32	g = self._get()
	33	self._put(item)		33	self._put(g)
	34			34
n	35	async def get(self, checker=None):	n	35	async def get(self, h=None):
	36	if checker is not None and checker in self:		36	if h is not None and h in self:
	37	while not checker(self.window):		37	while not h(self.window):
	38	self.later()		38	self.later()
	39	while self.empty():		39	while self.empty():
n	40	future = self._get_loop().create_future()	n	40	i = self._get_loop().create_future()
	41	self._getters.append(future)		41	self._getters.append(i)
	42	try:		42	try:
n	43	await future	n	43	await i
	44	except:		44	except:
n	45	future.cancel()	n	45	i.cancel()
	46	try:		46	try:
n	47	self._getters.remove(future)	n	47	self._getters.remove(i)
	48	except ValueError:		48	except ValueError:
	49	pass		49	pass
t	50	if not self.empty() and (not future.cancelled()):	t	50	if not self.empty() and (not i.cancelled()):
	51	self._wakeup_next(self._getters)		51	self._wakeup_next(self._getters)
	52	raise		52	raise
	53	return self.get_nowait()		53	return self.get_nowait()

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