U
vâ’iÓ ã @ sL d dl Z d dlmZ d dlmZmZmZmZ edƒZG dd„ dee ƒZ dS )é N)Úmaxsize)ÚGenericÚListÚTupleÚTypeVarÚ_T1c @ s| e Zd ZdZe Zddœdd„Zedœdd„Ze dœdd „Z
e dœd
d „Z e dd œd
d„Z e e
d œdd„Zddœdd„ZdS )Ú
PriorityQueuezDPriority queue for scheduling. Note that methods aren't thread-safe.N)Úreturnc C s g | _ tj| _d S )N©Úitemsr Ú MIN_COUNTÚcount©Úself© r úQ/opt/alt/python38/lib/python3.8/site-packages/reactivex/internal/priorityqueue.pyÚ__init__
s zPriorityQueue.__init__c C s
t | jƒS )zReturns length of queue)Úlenr r r r r Ú__len__ s zPriorityQueue.__len__c C s | j d d S )z/Returns first item in queue without removing itr )r r r r r Úpeek s zPriorityQueue.peekc C s" t | j¡d }| js tj| _|S )z8Returns and removes item with lowest priority from queuer )ÚheapqÚheappopr r r r
©r Úitemr r r Údequeue s zPriorityQueue.dequeue)r r c C s& t | j|| jf¡ | jd7 _dS )zAdds item to queueé N)r Úheappushr r
r r r r Úenqueue" s zPriorityQueue.enqueuec C sB t | jƒD ]2\}}|d |kr
| j |¡ t | j¡ dS q
dS )z Remove given item from queuer TF)Ú enumerater Úpopr Úheapify)r r ÚindexZ_itemr r r Úremove( s zPriorityQueue.removec C s g | _ tj| _dS )z Remove all items from the queue.Nr
r r r r Úclear3 s zPriorityQueue.clear)Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r r Úintr r r r r Úboolr" r# r r r r r s r )
r Úsysr Útypingr r r r r r r r r r Ú s