Алдабергенов Руслан Даниярович, 411 FilterQueue 17859			Абдикашева Вилена Ринатовна, 411 группа FilterQueue 17941
t	1	import asyncio	t	1	import asyncio
	2	from collections import deque		2	from collections import deque
	3			3
	4	class FilterQueue(asyncio.Queue):		4	class FilterQueue(asyncio.Queue):
	5			5
	6	def __init__(self, maxsize=0):		6	def __init__(self, maxsize=0):
	7	super().__init__(maxsize)		7	super().__init__(maxsize)
	8	self._window = None		8	self._window = None
	9			9
	10	def __contains__(self, filter_func):		10	def __contains__(self, filter_func):
	11	return any((filter_func(item) for item in self._queue))		11	return any((filter_func(item) for item in self._queue))
	12			12
	13	@property		13	@property
	14	def window(self):		14	def window(self):
	15	return self._queue[0] if not self.empty() else None		15	return self._queue[0] if not self.empty() else None
	16			16
	17	def later(self):		17	def later(self):
	18	if self.empty():		18	if self.empty():
	19	raise asyncio.QueueEmpty		19	raise asyncio.QueueEmpty
	20	item = self._queue.popleft()		20	item = self._queue.popleft()
	21	self._queue.append(item)		21	self._queue.append(item)
	22			22
	23	async def get(self, filter_func=None):		23	async def get(self, filter_func=None):
	24	if filter_func is None:		24	if filter_func is None:
	25	return await super().get()		25	return await super().get()
	26	for _ in range(len(self._queue)):		26	for _ in range(len(self._queue)):
	27	item = self._queue[0]		27	item = self._queue[0]
	28	if filter_func(item):		28	if filter_func(item):
	29	return await super().get()		29	return await super().get()
	30	self.later()		30	self.later()
	31	return await super().get()		31	return await super().get()

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