
    >a&
                     P   S SK r S SKrS SKrS SKJrJr  S SKJrJr  S SK	J
r
JrJr  SSKJr  \R                  R                   \R                  R!                  \(       + SS9/r\" S	S
SS9r\R&                  " 5       S 5       rS r\R&                  " 5       S 5       rS rS rS rS rg)    N)DBusAddressnew_method_call)message_bus	MatchRule)open_dbus_connectionopen_dbus_routerProxy   )have_session_buszTests require DBus session bus)reasonzorg.freedesktop.DBusz/org/freedesktop/DBuszorg.freedesktop.DBus.Peer)bus_nameobject_path	interfacec                    #    [        SS9I S h  vN  IS h  vN n U 7v   S S S 5      IS h  vN   g  N# N N	! , IS h  vN  (       d  f       g = f7fNSESSIONbus)r   conns    =lib/python3.13/site-packages/jeepney/io/tests/test_asyncio.py
connectionr      s1     *y9999d
 :99999sI   A3A5A9A7AAAAA AAc                 P   #    U R                   R                  S5      (       d   eg 7f)N:)unique_name
startswith)r   s    r   test_connectr       s"     !!,,S1111s   $&c                    #    [        SS9 IS h  vN n U 7v   S S S 5      IS h  vN   g  N N! , IS h  vN  (       d  f       g = f7fr   )r   )routers    r   r   r   #   s+     I..& /.....s9   A	+A	/A	-A	A	A8AA	c                    #    [        [        S5      n[        R                  " U R	                  U5      SS9I S h  vN nUR
                  S:X  d   eg  N7f)NPing   timeout )r   bus_peerasynciowait_forsend_and_get_replybody)r   	ping_callreplys      r   test_send_and_get_replyr-   (   sO     &1I""!!),a E ::s   8AAAc                    #    [        [        U 5      nSnUR                  U5      I S h  vN nUS;   d   eUR                  U5      I S h  vN u  nUSL d   eg  N/ N7f)Nz+io.gitlab.takluyver.jeepney.examples.Server>   r
      T)r	   r   RequestNameNameHasOwner)r   proxynameres	has_owners        r   
test_proxyr8   /   sd     +v&E8D!!$'
'C,))$//JI	 ( 0s!   'AA A
AAAc                 2  #    [        [        U 5      nSn[        S[        R                  [        R                  S[        R
                  S9nUR                  SU5        UR                  U5      I S h  vN   U R                  U5       nUR                  U5      I S h  vN u  nUS:X  d   e[        R                  " UR                  5       SS9I S h  vN nUR                  US	U R                  4:X  d   e S S S 5        g  N Nd N1! , (       d  f       g = f7f)
Nz5io.gitlab.takluyver.jeepney.tests.asyncio_test_filtersignalNameOwnerChanged)typesenderr   memberpathr   r
   g       @r#    )r	   r   r   r   r   r   add_arg_conditionAddMatchfilterr2   r'   r(   getr*   r   )r   r   r5   
match_rulequeuer6   
signal_msgs          r   test_filterrH   8   s     
V
$CBD##''!$$J   D) ,,z
"""	z	"e__T**axx"++EIIKEE
4V-?-?"@@@@ 
#	" # + F	 
#	"sN   A0D2D 3DDD4DD#D7
DDD
DDc                    #    [        SS9I S h  vN n  [        R                  " [        R                  5         [
        R                  " S5       IS h  vN   U R                  5       I S h  vN   S S S 5      IS h  vN   S S S 5        U R                  5       I S h  vN   g  N NO N9 N+! , IS h  vN  (       d  f       N@= f! , (       d  f       NI= f N8! U R                  5       I S h  vN    f = f7f)Nr   r   r   )	r   pytestraisesr'   TimeoutErrorasync_timeoutr$   receivecloser   s    r   test_recv_after_connectrP   O   s     
 &)44D]]7//0$,,Q//lln$$ 0/ 1 jjl 5 0$ 0/// 10 	djjls   C5B"C5$C CB$CB*,B&-B*1C<B(=CC 	C5CC5$C&B*(C*C	0B31C	=C
CC C5C2+C.,C22C5)r'   rM   rJ   jeepneyr   r   jeepney.bus_messagesr   r   jeepney.io.asyncior   r   r	   utilsr   markskipif
pytestmarkr&   fixturer   r   r   r-   r8   rH   rP   r%       r   <module>rZ      s       0 7  $ KK
KK%E  
 #')  2  A.rY   