+
    Si$                    ^   ^ RI Ht ^ RIt^ RIt^RIHtHtHt  ^ RIt ^ RItR R lt ! R R4      t ! R R	4      t ! R
 R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      t ! R R4      tR#   ]	]
3 d    Rt L~i ; i  ]	 d    Rt Li ; i)    )annotationsN)ExceptionMappingPoolTimeoutmap_exceptionsc                   V ^8  d   QhRR/# )   returnstr )formats   "n/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/httpcore/_synchronization.py__annotate__r      s      s     c                      ^ RI p V P                  4       pVR9  d   \        R4      hVR8X  d   \        f   \        R4      hVR8X  d   \
        f   \        R4      hV#   \         d    Rp LWi ; i)r   Nasynciotrioz/Running under an unsupported async environment.zBRunning with asyncio requires installation of 'httpcore[asyncio]'.z<Running with trio requires installation of 'httpcore[trio]'.)r   r   )sniffiocurrent_async_libraryImportErrorRuntimeErroranyior   )r   environments     r   r   r      s    6 335--LMMiEMP
 	
 fJ
 	
 %    s   A A.-A.c                  N    ] tR t^0tRtR R ltR R ltR R ltRR	 R
 lltRt	R# )	AsyncLock
This is a standard lock.

In the sync case `Lock` provides thread locking.
In the async case `AsyncLock` provides async locking.
c                   V ^8  d   QhRR/# r   r	   Noner   )r   s   "r   r   AsyncLock.__annotate__8         $ r   c                	    R V n         R#  N_backendselfs   &r   __init__AsyncLock.__init__8   	    r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   ;   s     	, 	,t 	,r   c                    \        4       V n        V P                  R8X  d   \        P                  ! 4       V n        R# V P                  R8X  d   \
        P                  ! 4       V n        R# R# zf
Detect if we're running under 'asyncio' or 'trio' and create
a lock with the correct implementation.
r   r   N)r   r%   r   Lock
_trio_lockr   _anyio_lockr&   s   &r   setupAsyncLock.setup;   sF    
 ./==F""iikDO]]i'$zz|D (r   c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   r   F   s     	 	) 	r   c                	*  "   V P                   '       g   V P                  4        V P                   R 8X  d%   V P                  P                  4       G Rj  xL
  V # V P                   R8X  d#   V P                  P                  4       G Rj  xL
  V #  L; L5ir   Nr   )r%   r1   r/   acquirer0   r&   s   &r   
__aenter__AsyncLock.__aenter__F   ss     }}}JJL==F"//))+++  ]]i'""**,,,	 ,,s$   ABB4BB	BBNc               (    V ^8  d   QhRRRRRRRR/# 	r   exc_typeztype[BaseException] | None	exc_valuezBaseException | None	tracebackztypes.TracebackType | Noner	   r   r   )r   s   "r   r   r   Q   s2     	' 	',	' (	' .		'
 
	'r   c                	   "   V P                   R 8X  d   V P                  P                  4        R# V P                   R8X  d   V P                  P                  4        R# R# 5ir   r   N)r%   r/   releaser0   r'   r;   r<   r=   s   &&&&r   	__aexit__AsyncLock.__aexit__Q   sF      ==F"OO##%]]i'$$& (   AA)r0   r%   r/   NNN)
__name__
__module____qualname____firstlineno____doc__r(   r1   r7   rB   __static_attributes__r   r   r   r   r   0   s     	,		' 	'r   r   c                  6    ] tR t^]tRtR R ltRR R lltRtR# )	AsyncThreadLock
This is a threading-only lock for no-I/O contexts.

In the sync case `ThreadLock` provides thread locking.
In the async case `AsyncThreadLock` is a no-op.
c                   V ^8  d   QhRR/# )r   r	   rM   r   )r   s   "r   r   AsyncThreadLock.__annotate__e   s      ? r   c                	    V # Nr   r&   s   &r   	__enter__AsyncThreadLock.__enter__e       r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   rP   h   2      , ( .	
 
r   c                	    R # rR   r   rA   s   &&&&r   __exit__AsyncThreadLock.__exit__h        	r   r   rE   )rF   rG   rH   rI   rJ   rS   rY   rK   r   r   r   rM   rM   ]   s     r   rM   c                  J    ] tR t^qtR R ltR R ltR R ltRR R	 lltR
tR# )
AsyncEventc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   AsyncEvent.__annotate__r   r    r   c                	    R V n         R# r"   r$   r&   s   &r   r(   AsyncEvent.__init__r   r*   r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r_   u   s     	. 	.t 	.r   c                    \        4       V n        V P                  R8X  d   \        P                  ! 4       V n        R# V P                  R8X  d   \
        P                  ! 4       V n        R# R# r-   )r   r%   r   Event_trio_eventr   _anyio_eventr&   s   &r   r1   AsyncEvent.setupu   sG    
 ./==F"#zz|D]]i' %D (r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r_      s     $ $T $r   c                	    V P                   '       g   V P                  4        V P                   R 8X  d   V P                  P                  4        R# V P                   R8X  d   V P                  P                  4        R# R# r?   )r%   r1   re   setrf   r&   s   &r   rj   AsyncEvent.set   sU    }}}JJL==F"  "]]i'!!# (r   Nc                    V ^8  d   QhRRRR/# r   timeoutzfloat | Noner	   r   r   )r   s   "r   r   r_      s     3 3, 3$ 3r   c           	     	<  "   V P                   '       g   V P                  4        V P                   R 8X  d   \        P                  \        /pVf   \        R4      MTp\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        V P                  P                  4       G Rj  xL
  RRR4       RRR4       R# V P                   R8X  dt   \        \        /p\        V4      ;_uu_ 4        \        P                  ! V4      ;_uu_ 4        V P                  P                  4       G Rj  xL
  RRR4       RRR4       R# R#  L  + '       g   i     L; i  + '       g   i     R# ; i LA  + '       g   i     LG; i  + '       g   i     R# ; i5i)r   Ninfr   )r%   r1   r   TooSlowErrorr   floatr   
fail_afterre   waitTimeoutErrorr   rf   )r'   rn   trio_exc_maptimeout_or_infanyio_exc_maps   &&   r   rt   AsyncEvent.wait   s    }}}JJL==F".2.?.?-ML-4_U5\'N--__^44**//111 5 .- ]]i'/;[.IM..%%g..++00222 / /. ( 2 54 .-- 3 /. /..s   A.F0EE	-E
.E	2E::F4FE5	1E32E5	6F>F
E	EEE0	*	F3E5	5F FF		F)rf   r%   re   rR   )	rF   rG   rH   rI   r(   r1   rj   rt   rK   r   r   r   r]   r]   q   s    	.$3 3r   r]   c                  F    ] tR t^tR R ltR R ltR R ltR R ltR	tR
# )AsyncSemaphorec                    V ^8  d   QhRRRR/# r   boundintr	   r   r   )r   s   "r   r   AsyncSemaphore.__annotate__   s      c d r   c                	     Wn         R V n        R# r"   )_boundr%   r'   r~   s   &&r   r(   AsyncSemaphore.__init__   s    r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r      s      t r   c                4   \        4       V n        V P                  R8X  d4   \        P                  ! V P                  V P                  R7      V n        R# V P                  R8X  d4   \        P                  ! V P                  V P                  R7      V n        R# R# )zk
Detect if we're running under 'asyncio' or 'trio' and create
a semaphore with the correct implementation.
r   )initial_value	max_valuer   N)r   r%   r   	Semaphorer   _trio_semaphorer   _anyio_semaphorer&   s   &r   r1   AsyncSemaphore.setup   si    
 ./==F"#'>>"kkT[[$D  ]]i'$)OO"kkT[[%D! (r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r      s     2 2t 2r   c                	.  "   V P                   '       g   V P                  4        V P                   R 8X  d%   V P                  P                  4       G Rj  xL
  R# V P                   R8X  d%   V P                  P                  4       G Rj  xL
  R# R#  L= L
5ir5   )r%   r1   r   r6   r   r&   s   &r   r6   AsyncSemaphore.acquire   sl     }}}JJL==F"&&..000]]i'''//111 ( 11s$   ABB4BB		BBc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r      s     , ,t ,r   c                	   "   V P                   R 8X  d   V P                  P                  4        R# V P                   R8X  d   V P                  P                  4        R# R# 5ir?   )r%   r   r@   r   r&   s   &r   r@   AsyncSemaphore.release   sF     ==F"  ((*]]i'!!))+ (rD   )r   r%   r   r   N)	rF   rG   rH   rI   r(   r1   r6   r@   rK   r   r   r   r{   r{      s    2, ,r   r{   c                  >    ] tR t^tR R ltR R ltR	R R lltRtR# )
AsyncShieldCancellationc                   V ^8  d   QhRR/# r   r   )r   s   "r   r   $AsyncShieldCancellation.__annotate__   s     
@ 
@$ 
@r   c                    \        4       V n        V P                  R8X  d   \        P                  ! RR7      V n        R# V P                  R8X  d   \
        P                  ! RR7      V n        R# R# )zp
Detect if we're running under 'asyncio' or 'trio' and create
a shielded scope with the correct implementation.
r   T)shieldr   N)r   r%   r   CancelScope_trio_shieldr   _anyio_shieldr&   s   &r   r(    AsyncShieldCancellation.__init__   sQ    
 ./==F" $ 0 0 =D]]i'!&!2!2$!?D (r   c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   r      s      2 r   c                	    V P                   R 8X  d   V P                  P                  4        V # V P                   R8X  d   V P                  P                  4        V # )r   r   )r%   r   rS   r   r&   s   &r   rS   !AsyncShieldCancellation.__enter__   sL    ==F"'')  ]]i'((*r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r      s8     	H 	H,	H (	H .		H
 
	Hr   c                	    V P                   R 8X  d   V P                  P                  WV4       R# V P                   R8X  d   V P                  P                  WV4       R# R# r?   )r%   r   rY   r   rA   s   &&&&r   rY    AsyncShieldCancellation.__exit__   sM     ==F"&&xIF]]i'''YG (r   )r   r%   r   rE   )rF   rG   rH   rI   r(   rS   rY   rK   r   r   r   r   r      s    
@	H 	Hr   r   c                  B    ] tR t^tRtR R ltR R ltR
R R lltR	tR# )r.   r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   Lock.__annotate__        & &$ &r   c                	:    \         P                  ! 4       V n        R # rR   	threadingr.   _lockr&   s   &r   r(   Lock.__init__       ^^%
r   c                   V ^8  d   QhRR/# )r   r	   r.   r   )r   s   "r   r   r      s      4 r   c                	:    V P                   P                  4        V # rR   r   r6   r&   s   &r   rS   Lock.__enter__       

r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r      2      , ( .	
 
r   c                	:    V P                   P                  4        R # rR   r   r@   rA   s   &&&&r   rY   Lock.__exit__        	

r   r   rE   	rF   rG   rH   rI   rJ   r(   rS   rY   rK   r   r   r   r.   r.          & r   r.   c                  B    ] tR tRtRtR R ltR R ltRR R	 lltR
tR# )
ThreadLock   rN   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   ThreadLock.__annotate__  r   r   c                	:    \         P                  ! 4       V n        R # rR   r   r&   s   &r   r(   ThreadLock.__init__  r   r   c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   r     s      : r   c                	:    V P                   P                  4        V # rR   r   r&   s   &r   rS   ThreadLock.__enter__  r   r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r     r   r   c                	:    V P                   P                  4        R # rR   r   rA   s   &&&&r   rY   ThreadLock.__exit__  r   r   r   rE   r   r   r   r   r   r      r   r   r   c                  >    ] tR tRtR R ltR R ltR
R R lltR	tR# )rd   i  c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   Event.__annotate__  s     ( ($ (r   c                	:    \         P                  ! 4       V n        R # rR   )r   rd   _eventr&   s   &r   r(   Event.__init__  s    oo'r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r     s      T r   c                	:    V P                   P                  4        R # rR   )r   rj   r&   s   &r   rj   	Event.set  s    r   Nc                    V ^8  d   QhRRRR/# rm   r   )r   s   "r   r   r     s        L  D  r   c                	    V\        R 4      8X  d   RpV P                  P                  VR7      '       g   \        4       hR# )rp   N)rn   )rr   r   rt   r   )r'   rn   s   &&r   rt   
Event.wait  s8    eEl"G{{00- 1r   )r   rR   )rF   rG   rH   rI   r(   rj   rt   rK   r   r   r   rd   rd     s    (   r   rd   c                  :    ] tR tRtR R ltR R ltR R ltRtR	# )
r   i&  c                    V ^8  d   QhRRRR/# r}   r   )r   s   "r   r   Semaphore.__annotate__'  s     ; ;c ;d ;r   c                	>    \         P                  ! VR 7      V n        R# ))valueN)r   r   
_semaphorer   s   &&r   r(   Semaphore.__init__'  s    #--E:r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   *       " " "r   c                	:    V P                   P                  4        R # rR   )r   r6   r&   s   &r   r6   Semaphore.acquire*      !r   c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   -  r   r   c                	:    V P                   P                  4        R # rR   )r   r@   r&   s   &r   r@   Semaphore.release-  r   r   )r   N)rF   rG   rH   rI   r(   r6   r@   rK   r   r   r   r   r   &  s    ;"" "r   r   c                  2    ] tR tRtR R ltRR R lltRtR# )	ShieldCancellationi1  c                   V ^8  d   QhRR/# )r   r	   r   r   )r   s   "r   r   ShieldCancellation.__annotate__5  s      - r   c                	    V # rR   r   r&   s   &r   rS   ShieldCancellation.__enter__5  rU   r   Nc               (    V ^8  d   QhRRRRRRRR/# r:   r   )r   s   "r   r   r   8  rW   r   c                	    R # rR   r   rA   s   &&&&r   rY   ShieldCancellation.__exit__8  r[   r   r   rE   )rF   rG   rH   rI   rS   rY   rK   r   r   r   r   r   1  s     r   r   )
__future__r   r   types_exceptionsr   r   r   r   r   NotImplementedErrorr   r   r   rM   r]   r{   r   r.   r   rd   r   r   r   r   r   <module>r      s    "   F F

4*' *'Z (&3 &3R!, !,H$H $HT 0 0   " " I	 	() D
  Es"   B B  BB 	B,+B,