
    >a                     V    S SK Jr  S SKrS SKJr  S SKJrJrJr  S SK	J
r
  S rS rS rg)	    )FutureN)Router)new_method_return	new_errorDBusErrorResponse)message_busc                      [        [        5      n [        R                  " 5       nU R	                  U5      nU R                  [        USS5      5        UR                  5       S:X  d   eg )Ns)test)r   r   r   Hellooutgoingincomingr   result)routercallfutures      :lib/python3.13/site-packages/jeepney/tests/test_routing.pytest_message_replyr      sQ    F^FD__T"F
OO%dC;<==?i'''    c                     [        [        5      n [        R                  " 5       nU R	                  U5      nU R                  [        USSS5      5        [        R                  " [        5       nUR                  5         S S S 5        WR                  R                  S:X  d   eUR                  R                  S:X  d   eg ! , (       d  f       NG= f)N	TestErroru)   )r   r   r   r   r   r   r   pytestraisesr   r   valuenamedata)r   r   r   es       r   
test_errorr       s    F^FD__T"F
OOIdKe<=	(	)Q 
*77<<;&&&77<<5    
*	)s   -B??
Cc                      / n [        [        U R                  S9n[        R                  " 5       nUR                  U5        [        U 5      S:X  d   eU S   U:X  d   eg )N)on_unhandled   r   )r   r   appendr   r   r   len)	unhandledr   msgs      r   test_unhandledr(      sW    IF)9)9:F



C
OOCy>QQ<3r   )asyncior   r   jeepney.routingr   jeepney.wrappersr   r   r   jeepney.bus_messagesr   r   r    r(    r   r   <module>r.      s&      " L L ,(!r   