0x1949 Team - FAZEMRX - MANAGER
Edit File: 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 � method_callr r )r �msg�handler 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 �signal�fields�getr r r r! r �body� reply_serialr �pop� method_return� set_result�error� set_exceptionr r )r r �hdr�key�cbr( � reply_handler r r �incoming0 s, � �zRouter.incomingr ) �__name__� __module__� __qualname__�__doc__r �propertyr �setterr r" r2 r r r r r s r N)�warningsr � low_levelr r �wrappersr r r r r r �<module> s