§
     @gÛ  ã                   óŠ   — d dl mZmZ d dlZd dlmZ d dlmZ  G d„ de¦  «        Z G d„ de¦  «        Z	 G d	„ d
e	¦  «        Z
dS )é    )ÚABCÚabstractmethodN)ÚQueue)ÚIteratorc                   ó   — e Zd ZdS )ÚQueueItemBaseN)Ú__name__Ú
__module__Ú__qualname__© ó    úG/var/www/piapp/venv/lib/python3.11/site-packages/aiproxy/queueclient.pyr   r      s   € € € € € Ø€Cr   r   c                   óV   — e Zd ZdZedefd„¦   «         Zedee         fd„¦   «         ZdS )ÚQueueClientBaseç      à?Úitemc                 ó   — d S ©Nr   ©Úselfr   s     r   ÚputzQueueClientBase.put   ó   € àˆr   Úreturnc                 ó   — d S r   r   ©r   s    r   ÚgetzQueueClientBase.get   r   r   N)	r	   r
   r   Údequeue_intervalr   r   r   r   r   r   r   r   r   r      sk   € € € € € ØÐàð˜ð ð ð ñ „^ðð ð�X˜mÔ,ð ð ð ñ „^ðð ð r   r   c                   ó:   — e Zd Zdd„Zdefd„Zdee         fd„ZdS )ÚDefaultQueueClientr   Nc                 ó:   — t          ¦   «         | _        d| _        d S )Nr   )r   Úqueuer   r   s    r   Ú__init__zDefaultQueueClient.__init__   s   € Ý‘W”WˆŒ
Ø #ˆÔÐÐr   r   c                 ó:   — | j                              |¦  «         d S r   )r!   r   r   s     r   r   zDefaultQueueClient.put   s   € ØŒ
�Š�tÑÔÐÐÐr   c                 óà   — g }| j                              ¦   «         sE|                     | j                              ¦   «         ¦  «         | j                              ¦   «         ¯Et	          |¦  «        S r   )r!   ÚemptyÚappendr   Úiter)r   Úitemss     r   r   zDefaultQueueClient.get   s_   € ØˆØ”*×"Ò"Ñ$Ô$ð 	+Ø�LŠL˜œŸšÑ)Ô)Ñ*Ô*Ð*ð ”*×"Ò"Ñ$Ô$ð 	+å�E‰{Œ{Ðr   )r   N)r	   r
   r   r"   r   r   r   r   r   r   r   r   r      sc   € € € € € ð$ð $ð $ð $ð˜ð ð ð ð ð�X˜mÔ,ð ð ð ð ð ð r   r   )Úabcr   r   Újsonr!   r   Útypingr   r   r   r   r   r   r   ú<module>r,      sÒ   ðØ #Ð #Ð #Ð #Ð #Ð #Ð #Ð #Ø €€€Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð ðð ð ð ð �Cñ ô ð ð	ð 	ð 	ð 	ð 	�cñ 	ô 	ð 	ðð ð ð ð ˜ñ ô ð ð ð r   