U [e @s:ddlmZddlmZmZddlmZGdddZdS))warn) MessageType HeaderFields)DBusErrorResponsec@sLeZdZdZdddZeddZejddZdd 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_unhandledoutgoing_serialawaiting_replysignal_callbacks)selfr on_unhandledrQ/var/www/html/services/stratfitenv/lib/python3.8/site-packages/jeepney/routing.py__init__s zRouter.__init__cCs|jS)N)r )r rrrrszRouter.on_unhandledcCstddd||_dS)NzeSetting on_unhandled is deprecated. Please use the filter() method or simple receive() calls instead. stacklevel)rr )r valuerrrrscCsD|jd7_|j|j_|jjtjkr@||j|jj<}|SdS)zNSet the serial number in the message & make a handle if a method call rN)r headerserial message_typer method_callrr )r msghandlerrroutgoings  zRouter.outgoingcCs tddd||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 callbackpath interfacememberrrrsubscribe_signal)szRouter.subscribe_signalcCs|j}|jtjkrd|jtjd|jtjd|jtj df}|j |d}|dk rd||j dS|jtj d}|j |d}|dk r|jtjkr||j dS|jtjkr|t|dS|jr||dS)z#Route an incoming message. N)rrrsignalfieldsgetrrrr r body reply_serialr popZ method_return set_resulterror set_exceptionrr)r rhdrkeycbr'Z reply_handlerrrincoming0s*     zRouter.incoming)N) __name__ __module__ __qualname____doc__rpropertyrsetterrr!r/rrrrrs    rN)warningsrZ low_levelrrZwrappersrrrrrrs