
    ^f                    `    d Z ddlmZ ddlmZmZmZ ddlmZ d Z	d Z
d Zd Zd	 Zd
 Zd ZdS )zEvent-loop debugging tools.    )annotations)ERRREADWRITE)reprcallc                x    d                     | t          z  rdnd| t          z  rdnd| t          z  rdnd          S )z&Return description of event loop flag.z{}{}{}R W!)formatr   r   r   )flags    J/var/www/html/env/lib/python3.11/site-packages/kombu/asynchronous/debug.py	repr_flagr   	   sG    ??$+5332"&,633B"&*433"6 6 6    c                    | dS t          | t                    r| S t          | t                    r| \  }}t          |j        |          S | j        S )Nz	<missing>)args)
isinstancestrtupler   __name__)objcbr   s      r   _rcbr      s[    
{{#s 
#u 0D$////<r   c                f    d                     t          |           t          |           z             S )z1Return description of active readers and writers., )joinrepr_readersrepr_writershs    r   repr_activer"      s%    99\!__|A6777r   c                F     d                      fd|D                       S )z.Return description of events returned by poll.r   c              3     K   | ]H\  }}d                      t          t          ||d                    |t          |                    V  IdS )z
{}({})->{}z(GONE)N)r   r   callback_forr   ).0fdflr!   s      r   	<genexpr>zrepr_events.<locals>.<genexpr>"   sq        
 B	 	aR2233RbMM	
 	
     r   )r   )r!   eventss   ` r   repr_eventsr+       sA    99    
      r   c                H    d | j                                         D             S )z&Return description of pending readers.c                x    g | ]7\  }}d | dt          |           dt          t          t          z             8S ()z->)r   r   r   r   r&   r'   r   s      r   
<listcomp>z repr_readers.<locals>.<listcomp>-   sV     - - -B 988T"XX884#:!6!688 - - -r   )readersitemsr    s    r   r   r   +   /    - -)//++- - - -r   c                H    d | j                                         D             S )z&Return description of pending writers.c           
     h    g | ]/\  }}d | dt          |           dt          t                     0S r.   )r   r   r   r1   s      r   r2   z repr_writers.<locals>.<listcomp>3   sR     - - -B 433T"XX335!1!133 - - -r   )writersr4   r    s    r   r   r   1   r5   r   c                    	 |t           z  r| j        |         S |t          z  r|| j        v r| j        S | j        |         S dS # t          $ r |r
|d         cY S  w xY w)z)Return the callback used for hub+fd+flag.r   N)r   r3   r   consolidateconsolidate_callbackr8   KeyError)r!   r'   r   defaults       r   r%   r%   7   s    
$; 	!9R= %< 	!Q]""--9R= 	! 	!     	1:s   A A A AAN)__doc__
__future__r   kombu.utils.eventior   r   r   kombu.utils.functionalr   r   r   r"   r+   r   r   r%    r   r   <module>rC      s    ! ! " " " " " " 0 0 0 0 0 0 0 0 0 0 + + + + + +6 6 6  8 8 8
  - - -- - -    r   