+
    >a	                         R t ^ RIt^ RIHt ^ RIHtHt ^ RIHtH	t	H
t
Ht ^ RIHt ^ RIHt ^ RIHt ^ RIHt ]! R	^R
7        ! R R]P(                  4      t ! R R]4      tRR ltR# )z*Deprecated: use jeepney.io.asyncio insteadN)warn)ParserMessageType)AuthenticationErrorBEGINmake_auth_external
SASLParser)get_bus)message_bus)Router)	ProxyBasezOjeepney.integrate.asyncio is deprecated: please use jeepney.io.asyncio instead.)
stacklevelc                   J   a  ] tR t^t o R tR tR tR tR tR t	R t
RtV tR	# )
DBusProtocolc                    \        4       V n        \        4       V n        \	        \
        P                  4      V n        \
        P                  ! 4       V n        R V n	        R # N)
r   auth_parserr   parserr   asyncioFuturerouterauthenticationunique_nameselfs   &9lib/python3.14/site-packages/jeepney/integrate/asyncio.py__init__DBusProtocol.__init__   s<    %<hW^^,%nn.    c                f    Wn         V P                   P                  R \        4       ,           4       R# )    N)	transportwriter   )r   r!   s   &&r   connection_madeDBusProtocol.connection_made   s"    "U%7%99:r   c                    V P                   P                  \        4       V P                  P	                  R 4       V P
                  V n        V P                  V P                  P                  4       R# )TN)	r!   r"   r   r   
set_resultdata_received_post_authdata_receivedr   bufferr   s   &r   _authenticatedDBusProtocol._authenticated   sP    U#&&t,!994++223r   c                D   V P                   P                  V4       V P                   P                  '       d   V P                  4        R # V P                   P                  '       d;   V P
                  P                  \        V P                   P                  4      4       R # R # r   )r   feedauthenticatedr*   errorr   set_exceptionr   )r   datas   &&r   r(   DBusProtocol.data_received!   sq    d#)))!###--.A$BRBRBXBX.YZ $r   c                    V P                   P                  V4       F  pV P                  P                  V4       K   	  R # r   )r   r-   r   incoming)r   r1   msgs   && r   r'   $DBusProtocol.data_received_post_auth(   s-    ;;##D)CKK  % *r   c                    V P                   P                  4       '       g   \        R 4      hV P                  P	                  V4      pVP                  4       pV P                  P                  V4       V# )z/Wait for authentication before sending messages)r   doneRuntimeErrorr   outgoing	serialiser!   r"   )r   messagefuturer1   s   &&  r   send_messageDBusProtocol.send_message,   s\    ""''))PQQ%%g.  "T"r   c                   "   VP                   P                  \        P                  8w  d   \	        R 4      hV P                  V4      G Rj  xL
 #  L5i)z&Only method call messages have repliesN)headermessage_typer   method_call	TypeErrorr>   )r   r<   s   &&r   send_and_get_replyDBusProtocol.send_and_get_reply5   s@     >>&&+*A*AADEE&&w////s   A	AAA)r   r   r(   r   r   r!   r   N)__name__
__module____qualname____firstlineno__r   r#   r*   r(   r'   r>   rE   __static_attributes____classdictcell__)__classdict__s   @r   r   r      s.      ;4[&0 0r   r   c                   B   a a ] tR t^;t oRtV 3R ltR tR tRtVt	V ;t
# )ProxyzAn asyncio proxy for calling D-Bus methods

:param msggen: A message generator object.
:param DBusProtocol proto: Protocol object to send and receive messages.
c                2   < \         SV `  V4       W n        R # r   )superr   	_protocol)r   msggenprotocol	__class__s   &&&r   r   Proxy.__init__A   s     !r   c                N    R P                  V P                  V P                  4      # )zProxy({}, {}))format_msggenrR   r   s   &r   __repr__Proxy.__repr__E   s    %%dllDNNCCr   c                   a a VV 3R  lpV# )c                     <"   S! V / VB pVP                   P                  \        P                  J g   Q hSP                  P                  V4      G R j  xL
 #  L5ir   )rA   rB   r   rC   rR   rE   )argskwargsr5   make_msgr   s   *, r   inner!Proxy._method_call.<locals>.innerI   sN     D+F+C::**k.E.EEEE::3????s   AAAA )r   r`   ra   s   ff r   _method_callProxy._method_callH   s    	@
 r   )rR   )rG   rH   rI   rJ   __doc__r   rZ   rd   rK   rL   __classcell__)rU   rM   s   @@r   rO   rO   ;   s     
"D r   rO   c                 6  "   Vf   \         P                  ! 4       pVP                  \        \	        V 4      R7      G R j  xL
 w  r#VP
                  G R j  xL
  \        \        V4      p V P                  4       G R j  xL
 pV^ ,          Vn	        W#3#  LS L? L5i)N)path)
r   get_event_loopcreate_unix_connectionr   r	   r   rO   r
   Hellor   )buslooptphello_replys   &&   r   connect_and_authenticaterr   Q   s}     |%%'..|'#,.OOFQ



Q
C		#KNAM6M P#s4   =BB BB'B=B>BBB)SESSIONN)rf   r   warningsr   jeepneyr   r   jeepney.authr   r   r   r   jeepney.busr	   jeepney.bus_messagesr
   jeepney.routingr   jeepney.wrappersr   Protocolr   rO   rr   rc   r   r   <module>r|      sW    0   ' S S  , " &  *07## *0XI ,r   