
     @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            ^ Xm,    ^  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    WW
 #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_    *""$$ 	+LL))*** *""$$ 	+E{{r   )r   N)r	   r
   r   r"   r   r   r   r   r   r   r   r   r      sc        $ $ $ $    Xm,      r   r   )abcr   r   jsonr!   r   typingr   r   r   r   r   r   r   <module>r,      s    # # # # # # # #                 C   	 	 	 	 	c 	 	 	         r   