File: //usr/local/lib/python3.9/site-packages/kombu/__pycache__/abstract.cpython-39.pyc
a
X>hJ � @ s� d Z ddlmZ ddlmZ ddlmZmZmZmZ ddl m
Z
ddl m Z ddl
mZ ertdd lmZ dd
lmZ d Zed �Zed
dd�Zeddd�Zddd
d�dd�Zd d d�dd�ZG dd� d�ZG dd� de�Zd S ) zObject utilities.� )� annotations)�copy)�
TYPE_CHECKING�Any�Callable�TypeVar� )�
maybe_channel)�
NotBoundError)�ChannelPromise)�
Connection)�Channel)�Object�MaybeChannelBound�_T� _ObjectTyper )�bound�_MaybeChannelBoundTyper ztype[_ObjectType]�dict[str, Any])�cls�kwargs�returnc C s | f i |��S �N� )r r r r �8/usr/local/lib/python3.9/site-packages/kombu/abstract.py�
unpickle_dict s r )�vr c C s | S r r )r r r r �_any s r c @ sb e Zd ZU dZdZded< dddd�dd �Zdd d d
�dd�Zddd�dd�Zddd�dd�Z dS )r zYCommon base class.
Supports automatic kwargs->attributes handling, and cloning.
r ztuple[tuple[str, Any], ...]�attrsr �None)�argsr r c O sj | j D ]^\}}|�|�}|d ur6t| ||p,t|�� qzt| |� W q tyb t| |d � Y q0 qd S r )r �get�setattrr �getattr�AttributeError)�selfr r �name�type_�valuer r r �__init__, s
zObject.__init__F�boolr )�recurser c s. ddddd��fdd�
� � �fdd��j D �S ) Nr zCallable[[Any], Any] | None)�obj�typer c s2 � rt | t�r| jdd�S |r.| d ur.|| �S | S )NT�r+ )�
isinstancer �as_dict)r, r- r. r r �f8 s zObject.as_dict.<locals>.fc s" i | ]\}}|� t �|�|��qS r )r# )�.0�attrr- )r1 r% r r �
<dictcomp>< s z"Object.as_dict.<locals>.<dictcomp>)N)r )r% r+ r )r1 r+ r% r r0 7 s �zObject.as_dictr zktuple[Callable[[type[_ObjectType], dict[str, Any]], _ObjectType], tuple[type[_ObjectType], dict[str, Any]]])r% r c C s t | j| �� ffS r )r � __class__r0 �r% r r r �
__reduce__@ s zObject.__reduce__c C s | j f i | �� ��S r )r5 r0 r6 r r r �__copy__F s zObject.__copy__N)F)
�__name__�
__module__� __qualname__�__doc__r �__annotations__r) r0 r7 r8 r r r r r $ s
c @ s� e Zd ZU dZdZded< dZdZdddd�d d
�Zdddd�d d �Z dddd�d
d�Z
ddd�dd�Z dd�dd�Z dd�dd�Z
d#ddd�d d �Zed d�d d ��Zedd�d!d"��ZdS )$r z7Mixin for classes that can be bound to an AMQP channel.NzChannel | None�_channelFr zChannel | Connection)r% �channelr c C s
| � |�S )z&`self(channel) -> self.bind(channel)`.)�bind�r% r? 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_bindrA r r r r@ Y s zMaybeChannelBound.bindc C s& | j s"|r"t|�| _| �� d| _| S )z.Bind instance to channel if not already bound.T)�is_boundr r> �
when_bound� _is_boundrA r r r rC _ s
z MaybeChannelBound.maybe_bindr
r )r? r c C s | j r|| _| �� dS )zyRevive channel after the connection has been re-established.
Used by :meth:`~kombu.Connection.ensure`.
N)rD r> rE rA r r r �revivei s zMaybeChannelBound.revive)r c C s dS )z(Callback called when the class is bound.Nr r6 r r r rE s s z MaybeChannelBound.when_bound�strc C s | � t| �j�S r )� _repr_entityr- r9 r6 r r r �__repr__v s zMaybeChannelBound.__repr__� )�itemr c C s: |p t | �j}| jr.d�|p$t | �j| jj�S d|� d�S )Nz<{} bound to chan:{}>z <unbound �>)r- r9 rD �formatr? Z
channel_id)r% rL r r r rI y s �z MaybeChannelBound._repr_entityr* c C s | j o| jduS )z!Flag set if the channel is bound.N)rF r> r6 r r r rD � s zMaybeChannelBound.is_boundc C s< | j }|du r"td�t| �j���t|t�r8|� }| _ |S )z'Current channel if the object is bound.Nz.Can't call method on {} not bound to a channel)r> r
rN r- r9 r/ r rA r r r r? � s ��
zMaybeChannelBound.channel)rK )r9 r: r; r< r> r= rF Zcan_cache_declarationrB r@ rC rG rE rJ rI �propertyrD r? r r r r r J s
N)r< �
__future__r r �typingr r r r �
connectionr �
exceptionsr
Zutils.functionalr Zkombu.connectionr Zkombu.transport.virtualr
�__all__r r r r r r r r r r r �<module> s& �&