Name	Size	Mode	Actions
auth.cpython-310.pyc	4991	0644	editdlrm
bindgen.cpython-310.pyc	4457	0644	editdlrm
bus.cpython-310.pyc	1978	0644	editdlrm
bus_messages.cpython-310.pyc	8270	0644	editdlrm
fds.cpython-310.pyc	5619	0644	editdlrm
low_level.cpython-310.pyc	20434	0644	editdlrm
routing.cpython-310.pyc	2782	0644	editdlrm
wrappers.cpython-310.pyc	8835	0644	editdlrm
__init__.cpython-310.pyc	678	0644	editdlrm

o ���`�@s:dd
lm
Z

ddlmZmZ
ddlmZ
Gdd�d�ZdS)�)
�warn�
)�MessageType�HeaderFields)
�DBusErrorResponsec@sLeZ
dZd
Zddd�
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. NcCs"|
|_||_
d
|_i|_i|_dS)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


Cs|jS�
N)
r )
r rrrrszRouter.on_unhandledcCstd
dd�
|
|_
dS)NzeSetting on_unhandled is deprecated. Please use the filter() method or simple receive() calls instead.��
� stacklevel)rr )r �valuerrrrs
� cCsD|jd
7_|j|
j
_|
j
jtjur |��|j|
j
j<}|SdS)zNSet the serial number in the message & make a handle if a method call rN)r �header�serial�message_typer�method_callrr)r �msg�handlerrr�outgoings


�zRouter.outgoingcCs td
dd�
|
|j
|||f<dS)z%Add a callback for a signal. zQThe subscribe_signal() method is deprecated. Please use the filter() API instead.rrN)rr)r �callback�path� interface�memberrrr�subscribe_signal)s
�zRouter.subscribe_signalcCs�|
j}|j
tjur2|j�tjd
�|j�tjd
�|j�tj d
�f}|j �|d
�}|d
u
r2||
j�

d
S|j�tjd�}|j �|d
�}|d
u
rb|j
tjurS|�|
j�

d
S|j
tjurb|�t|
�
�

d
S|jrl|�|
�

d
Sd
S)z#Route an incoming message. N�����)rrr�signal�fields�getrrr r!r�body�reply_serialr�pop� method_return� set_result�error� set_exceptionrr)r r�hdr�key�cbr(�reply_handlerrr�incoming0s,


�











�zRouter.incomingr)�__name__� __module__�__qualname__�__doc__r�propertyr�setterrr"r2rrrrrs


 rN)�warningsr� low_levelrr�wrappersrrrrrr�
s