File: //proc/self/root/lib/python3/dist-packages/jeepney/__pycache__/routing.cpython-310.pyc
o
���` � @ s: d dl mZ ddlmZmZ ddlmZ G dd� d�ZdS )� )�warn� )� MessageType� HeaderFields)�DBusErrorResponsec @ sL e Zd ZdZddd�Zedd� �Zejdd� �Zdd � Zd
d � Z d d
� Z
dS )�Routera[ Routing for messages coming back to a client application.
:param handle_factory: Constructor for an object like asyncio.Future,
with methods *set_result* and *set_exception*. Outgoing method call
messages will get a handle associated with them.
:param on_unhandled: Callback for messages not otherwise dispatched.
Nc C s" || _ || _d| _i | _i | _d S )Nr )�handle_factory�
_on_unhandled�outgoing_serial�awaiting_reply�signal_callbacks)�selfr � on_unhandled� r �1/usr/lib/python3/dist-packages/jeepney/routing.py�__init__ s
zRouter.__init__c C s | j S �N)r )r
r r r r s zRouter.on_unhandledc C s t ddd� || _d S )NzeSetting on_unhandled is deprecated. Please use the filter() method or simple receive() calls instead.� ��
stacklevel)r r )r
�valuer r r r s �
c C sD | j d7 _ | j |j_|jjtju r | �� | j|jj< }|S dS )zNSet the serial number in the message & make a handle if a method call
r N)r
�header�serial� message_typer Z method_callr r )r
�msgZhandler r r �outgoing s
�zRouter.outgoingc C s t ddd� || j|||f< dS )z%Add a callback for a signal.
zQThe subscribe_signal() method is deprecated. Please use the filter() API instead.r r N)r r )r
�callback�path� interface�memberr r r �subscribe_signal) s �zRouter.subscribe_signalc C s� |j }|jtju r2|j�tjd�|j�tjd�|j�tj d�f}| j
�|d�}|dur2||j � dS |j�tj d�}| j
�|d�}|durb|jtju rS|�|j � dS |jtju rb|�t|�� dS | jrl| �|� dS dS )z#Route an incoming message.
N���)r r r �signalZfields�getr r r r r �body� reply_serialr �popZ
method_returnZ
set_result�errorZ
set_exceptionr r )r
r Zhdr�key�cbr% Z reply_handler r r �incoming0 s, �
�zRouter.incomingr ) �__name__�
__module__� __qualname__�__doc__r �propertyr �setterr r r* r r r r r s
r N)�warningsr Z low_levelr r Zwrappersr r r r r r �<module> s