File: //home/arjun/projects/env/lib/python3.10/site-packages/kombu/__pycache__/abstract.cpython-310.pyc
o
'weJ � @ s� d Z ddlmZ ddlmZ ddlmZmZmZmZ ddl m
Z
ddl m Z ddl
mZ er:dd lmZ dd
lmZ d Zed �Zed
dd�Zeddd�Zd dd�Zd dd�ZG d d� d�ZG d d� de�Zd S )!zObject utilities.� )� annotations)�copy)�
TYPE_CHECKING�Any�Callable�TypeVar� )�
maybe_channel)�
NotBoundError)�ChannelPromise)�
Connection)�Channel)�Object�MaybeChannelBound�_T� _ObjectTyper )�bound�_MaybeChannelBoundTyper �cls�type[_ObjectType]�kwargs�dict[str, Any]�returnc C s | di |��S �N� r )r r r r �G/home/arjun/projects/env/lib/python3.10/site-packages/kombu/abstract.py�
unpickle_dict s r �vc C s | S �Nr )r r r r �_any s r c @ sH e Zd ZU dZdZded< dd
d �Zdd dd�Zd dd�Zd dd�Z dS ) r zYCommon base class.
Supports automatic kwargs->attributes handling, and cloning.
r ztuple[tuple[str, Any], ...]�attrs�argsr r r �Nonec O sh | j D ].\}}|�|�}|d urt| ||pt|�� qzt| |� W q ty1 t| |d � Y qw d S r )r �get�setattrr �getattr�AttributeError)�selfr! r �name�type_�valuer r r �__init__, s
��zObject.__init__F�recurse�boolr c s& d
d �fdd�
� � �fdd ��j D �S ) N�objr �type�Callable[[Any], Any] | Noner c s2 � r
t | t�r
| jdd�S |r| d ur|| �S | S )NT�r, )�
isinstancer �as_dict)r. r/ r1 r r �f8 s zObject.as_dict.<locals>.fc s" i | ]
\}}|� t �|�|��qS r )r% )�.0�attrr/ )r4 r' r r �
<dictcomp>< s �z"Object.as_dict.<locals>.<dictcomp>r )r. r r/ r0 r r )r )r' r, r )r4 r, r' r r3 7 s �zObject.as_dictr' r �ktuple[Callable[[type[_ObjectType], dict[str, Any]], _ObjectType], tuple[type[_ObjectType], dict[str, Any]]]c C s t | j| �� ffS r )r � __class__r3 �r' r r r �
__reduce__@ s zObject.__reduce__c C s | j di | �� ��S r )r9 r3 r: r r r �__copy__F s zObject.__copy__N)r! r r r r r" )F)r, r- r r )r' r r r8 )r' r r r )
�__name__�
__module__� __qualname__�__doc__r �__annotations__r+ r3 r; r< r r r r r $ s
c @ s� e Zd ZU dZdZded< dZdZd#d d �Zd#d
d�Z d#dd�Z
d$dd�Z d%dd�Z d&dd�Z
d'd(d d �Zed)d d ��Zed*d!d"��ZdS )+r z7Mixin for classes that can be bound to an AMQP channel.NzChannel | None�_channelFr' r �channel�Channel | Connectionr c C s
| � |�S )z&`self(channel) -> self.bind(channel)`.)�bind�r' rC r r r �__call__S s
zMaybeChannelBound.__call__c C s t | ��|�S )z7Create copy of the instance that is bound to a channel.)r �
maybe_bindrF r r r rE Y s zMaybeChannelBound.bindc C s& | j s|rt|�| _| �� d| _| S )z.Bind instance to channel if not already bound.T)�is_boundr rB �
when_bound� _is_boundrF r r r rH _ s
z MaybeChannelBound.maybe_bindr
r" c C s | j r || _| �� dS dS )zyRevive channel after the connection has been re-established.
Used by :meth:`~kombu.Connection.ensure`.
N)rI rB rJ rF r r r �revivei s �zMaybeChannelBound.revivec C s dS )z(Callback called when the class is bound.Nr r: r r r rJ s s z MaybeChannelBound.when_bound�strc C s | � t| �j�S r )� _repr_entityr/ r= r: r r r �__repr__v s zMaybeChannelBound.__repr__� �itemc C s: |pt | �j}| jrd�|pt | �j| jj�S d|� d�S )Nz<{} bound to chan:{}>z <unbound �>)r/ r= rI �formatrC �
channel_id)r' rQ r r r rN y s � z MaybeChannelBound._repr_entityr- c C s | j o| jduS )z!Flag set if the channel is bound.N)rK rB r: r r r rI � s zMaybeChannelBound.is_boundc C s< | j }|du rtd�t| �j���t|t�r |� }| _ |S )z'Current channel if the object is bound.Nz.Can't call method on {} not bound to a channel)rB r
rS r/ r= r2 r rF r r r rC � s ��
zMaybeChannelBound.channel)r' r rC rD r r )rC r
r r" )r r" )r rM )rP )rQ rM r rM )r r- )r r
)r= r> r? r@ rB rA rK �can_cache_declarationrG rE rH rL rJ rO rN �propertyrI rC r r r r r J s
N)r r r r r r )r r r r )r@ �
__future__r r �typingr r r r �
connectionr �
exceptionsr
�utils.functionalr �kombu.connectionr �kombu.transport.virtualr
�__all__r r r r r r r r r r r �<module> s( �
&