File: //usr/local/lib/python3.9/site-packages/kombu/asynchronous/__pycache__/debug.cpython-39.pyc
a
X>h� � @ sl d Z ddlmZ ddlmZmZmZ ddlmZ dd� Z dd� Z
d d
� Z d d � Z d
d� Z
dd� Zdd� ZdS )zEvent-loop debugging tools.� )� annotations)�ERR�READ�WRITE)�reprcallc C s2 d� | t@ rdnd| t@ r dnd| t@ r,dnd�S )z&Return description of event loop flag.z{}{}{}�R� �W�!)�formatr r r )�flag� r
�B/usr/local/lib/python3.9/site-packages/kombu/asynchronous/debug.py� repr_flag s �r c C s@ | d u r dS t | t�r| S t | t�r:| \}}t|j|d�S | jS )Nz <missing>)�args)�
isinstance�str�tupler �__name__)�obj�cbr r
r
r �_rcb s
r c C s d� t| �t| � �S )z1Return description of active readers and writers.�, )�join� repr_readers� repr_writers��hr
r
r � repr_active s r c s d� � fdd�|D ��S )z.Return description of events returned by poll.r c 3 s2 | ]*\}}d � tt� ||d��|t|��V qdS )z
{}({})->{}z(GONE)N)r r � callback_forr )�.0�fd�flr r
r � <genexpr>" s
��z repr_events.<locals>.<genexpr>)r )r �eventsr
r r � repr_events s �r% c C s dd� | j �� D �S )z&Return description of pending readers.c
S s2 g | ]*\}}d |� dt |�� dtttB �� ��qS ��(�)z->)r r r r �r r! r r
r
r �
<listcomp>- s �z repr_readers.<locals>.<listcomp>)�readers�itemsr r
r
r r + s �r c C s dd� | j �� D �S )z&Return description of pending writers.c S s. g | ]&\}}d |� dt |�� dtt�� ��qS r& )r r r r) r
r
r r* 3 s �z repr_writers.<locals>.<listcomp>)�writersr, r r
r
r r 1 s �r c G sh z>|t @ r| j| W S |t@ r<|| jv r0| jW S | j| W S W n$ tyb |r\|d Y S � Y n0 dS )z)Return the callback used for hub+fd+flag.r N)r r+ r Z consolidateZconsolidate_callbackr- �KeyError)r r! r �defaultr
r
r r 7 s
r N)�__doc__�
__future__r Zkombu.utils.eventior r r Zkombu.utils.functionalr r r r r% r r r r
r
r
r �<module> s