B Rœ±[. ã@s.ddlmZmZddlmZGdd„dƒZdS)é)Ú MessageTypeÚ HeaderFields)ÚDBusErrorResponsec@s2eZdZdZd dd„Zdd„Zdd„Zd d „ZdS) Ú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)Né)Úhandle_factoryÚ on_unhandledÚoutgoing_serialÚawaiting_replyÚsignal_callbacks)Úselfrr©r ú.lib/python3.7/site-packages/jeepney/routing.pyÚ__init__ s zRouter.__init__cCsD|jd7_|j|j_|jjtjkr@| ¡|j|jj<}|SdS)zNSet the serial number in the message & make a handle if a method call rN)r ÚheaderÚserialÚ message_typerZ method_callrr )r ÚmsgZhandler r rÚoutgoings  zRouter.outgoingcCs||j|||f<dS)z%Add a callback for a signal. N)r )r ÚcallbackÚpathÚ interfaceÚmemberr r rÚsubscribe_signalszRouter.subscribe_signalcCsØ|j}|jtjkrd|j tjd¡|j tjd¡|j tj d¡f}|j  |d¡}|dk rd||j ƒdS|j tj d¡}|j  |d¡}|dk rÄ|jtjkr¦| |j ¡dS|jtjkrÄ| t|ƒ¡dS|jrÔ| |¡dS)z#Route an incoming message. Néÿÿÿÿ)rrrÚsignalZfieldsÚgetrrrrr ZbodyÚ reply_serialr ÚpopZ method_returnZ set_resultÚerrorZ set_exceptionrr)r rZhdrÚkeyÚcbrZ reply_handler r rÚincoming"s(     zRouter.incoming)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrr"r r r rrs   rN)Z low_levelrrZwrappersrrr r r rÚs