+
     h$  c                  s^   ^ 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/# )   returnZstr Zformat   ">/usr/lib/python3.14/site-packages/httpcore/_synchronization.py__annotate__r      s      s     c                 s     ^ 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ImportErrorZRuntimeErroranyior   )r   Zenvironments     r   r   r      s    6 335--LMMiEMP
 	
 fJ
 	
 %    s   A A.-A.c                  sN    ] 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               r   r   r   Noner   r	   r
   r   r   AsyncLock.__annotate__8         $ r   c                	    R V n         R# Z N_backendself   &r   __init__ZAsyncLock.__init__8   	    r   c               r   r   r   r	   r
   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   r    r   setupZAsyncLock.setup;   sF    
 ./==F""iikDO]]i'$zz|D (r   c               r   )r   r   r   r   r	   r
   r   r   r   F   s     	 	) 	r   c                	s*  "   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   r(   r&   acquirer'   r   r    r   
__aenter__Z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	   r
   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&   releaser'   r   r.   r/   r0      &&&&r   	__aexit__ZAsyncLock.__aexit__Q   sF      ==F"OO##%]]i'$$& (   AA)r'   r   r&   NNN)
__name__
__module____qualname____firstlineno____doc__r!   r(   r+   r6   __static_attributes__r   r   r   r   r   0   s     	,		' 	'r   r   c                  s6    ] 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               r   )r   r   r?   r   r	   r
   r   r   AsyncThreadLock.__annotate__e   s      ? r   c                	    V # Nr   r   r    r   	__enter__ZAsyncThreadLock.__enter__e       r   Nc               r,   r-   r   r	   r
   r   r   rA   h   2      , ( .	
 
r   c                	    R # rC   r   r4   r5   r   __exit__ZAsyncThreadLock.__exit__h        	r   r   r8   )r9   r:   r;   r<   r=   rD   rH   r>   r   r   r   r?   r?   ]   s     r   r?   c                  sJ    ] 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               r   r   r   r	   r
   r   r   AsyncEvent.__annotate__r   r   r   c                	r   r   r   r   r    r   r!   ZAsyncEvent.__init__r   r"   r   c               r   r   r   r	   r
   r   r   rK   u   s     	. 	.t 	.r   c                r#   r$   )r   r   r   Event_trio_eventr   _anyio_eventr   r    r   r(   ZAsyncEvent.setupu   sG    
 ./==F"#zz|D]]i' %D (r   c               r   r   r   r	   r
   r   r   rK      s     $ $T $r   c                	s    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# r2   )r   r(   rM   setrN   r   r    r   rO   ZAsyncEvent.set   sU    }}}JJL==F"  "]]i'!!# (r   Nc                    V ^8  d   QhRRRR/# r   timeoutzfloat | Noner   r   r   r	   r
   r   r   rK      s     3 3, 3$ 3r   c           	     	s<  "   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   r(   r   ZTooSlowErrorr   floatr   Z
fail_afterrM   waitZTimeoutErrorr   rN   )r   rR   Ztrio_exc_mapZtimeout_or_infZanyio_exc_maps   &&   r   rU   Z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)rN   r   rM   rC   )	r9   r:   r;   r<   r!   r(   rO   rU   r>   r   r   r   rJ   rJ   q   s    	.$3 3r   rJ   c                  sF    ] tR t^tR R ltR R ltR R ltR R ltR	tR
# )AsyncSemaphorec               rP   r   boundZintr   r   r   r	   r
   r   r   AsyncSemaphore.__annotate__   s      c d r   c                	s     Wn         R V n        R# r   )_boundr   r   rX      &&r   r!   ZAsyncSemaphore.__init__   s    r   c               r   r   r   r	   r
   r   r   rY      s      t r   c                s4   \        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   )Zinitial_valueZ	max_valuer   N)r   r   r   	SemaphorerZ   _trio_semaphorer   _anyio_semaphorer   r    r   r(   ZAsyncSemaphore.setup   si    
 ./==F"#'>>"kkT[[$D  ]]i'$)OO"kkT[[%D! (r   c               r   r   r   r	   r
   r   r   rY      s     2 2t 2r   c                	s.  "   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r)   )r   r(   r^   r*   r_   r   r    r   r*   ZAsyncSemaphore.acquire   sl     }}}JJL==F"&&..000]]i'''//111 ( 11s$   ABB4BB		BBc               r   r   r   r	   r
   r   r   rY      s     , ,t ,r   c                	r1   r2   )r   r^   r3   r_   r   r    r   r3   ZAsyncSemaphore.release   sF     ==F"  ((*]]i'!!))+ (r7   )r_   r   rZ   r^   N)	r9   r:   r;   r<   r!   r(   r*   r3   r>   r   r   r   rV   rV      s    2, ,r   rV   c                  s>    ] tR t^tR R ltR R ltR	R R lltRtR# )
AsyncShieldCancellationc               r   r   r   r	   r
   r   r   $AsyncShieldCancellation.__annotate__   s     
@ 
@$ 
@r   c                s    \        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)Zshieldr   N)r   r   r   ZCancelScope_trio_shieldr   _anyio_shieldr   r    r   r!   Z AsyncShieldCancellation.__init__   sQ    
 ./==F" $ 0 0 =D]]i'!&!2!2$!?D (r   c               r   )r   r   r`   r   r	   r
   r   r   ra      s      2 r   c                	s    V P                   R 8X  d   V P                  P                  4        V # V P                   R8X  d   V P                  P                  4        V # )r   r   )r   rb   rD   rc   r   r    r   rD   Z!AsyncShieldCancellation.__enter__   sL    ==F"'')  ]]i'((*r   Nc               r,   r-   r   r	   r
   r   r   ra      s8     	H 	H,	H (	H .		H
 
	Hr   c                	s    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# r2   )r   rb   rH   rc   r4   r5   r   rH   Z AsyncShieldCancellation.__exit__   sM     ==F"&&xIF]]i'''YG (r   )rc   r   rb   r8   )r9   r:   r;   r<   r!   rD   rH   r>   r   r   r   r`   r`      s    
@	H 	Hr   r`   c                  sB    ] 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               r   r   r   r	   r
   r   r   Lock.__annotate__        & &$ &r   c                	:    \         P                  ! 4       V n        R # rC   	threadingr%   _lockr   r    r   r!   ZLock.__init__       ^^%
r   c               r   )r   r   r%   r   r	   r
   r   r   rd      s      4 r   c                	:    V P                   P                  4        V # rC   ri   r*   r   r    r   rD   ZLock.__enter__       

r   Nc               r,   r-   r   r	   r
   r   r   rd      2      , ( .	
 
r   c                	:    V P                   P                  4        R # rC   ri   r3   r4   r5   r   rH   ZLock.__exit__        	

r   ri   r8   	r9   r:   r;   r<   r=   r!   rD   rH   r>   r   r   r   r%   r%          & r   r%   c                  sB    ] tR tRtRtR R ltR R ltRR R	 lltR
tR# )
ThreadLocki   r@   c               r   r   r   r	   r
   r   r   ThreadLock.__annotate__  re   r   c                	rf   rC   rg   r   r    r   r!   ZThreadLock.__init__  rj   r   c               r   )r   r   ru   r   r	   r
   r   r   rv     s      : r   c                	rk   rC   rl   r   r    r   rD   ZThreadLock.__enter__  rm   r   Nc               r,   r-   r   r	   r
   r   r   rv     rn   r   c                	ro   rC   rp   r4   r5   r   rH   ZThreadLock.__exit__  rq   r   rr   r8   rs   r   r   r   ru   ru      rt   r   ru   c                  s>    ] tR tRtR R ltR R ltR
R R lltR	tR# )rL   i  c               r   r   r   r	   r
   r   r   Event.__annotate__  s     ( ($ (r   c                	rf   rC   )rh   rL   _eventr   r    r   r!   ZEvent.__init__  s    oo'r   c               r   r   r   r	   r
   r   r   rw     s      T r   c                	ro   rC   )rx   rO   r   r    r   rO   Z	Event.set  s    r   Nc               rP   rQ   r   r	   r
   r   r   rw     s        L  D  r   c                	s    V\        R 4      8X  d   RpV P                  P                  VR7      '       g   \        4       hR# )rS   N)rR   )rT   rx   rU   r   )r   rR   r\   r   rU   Z
Event.wait  s8    eEl"G{{00- 1r   )rx   rC   )r9   r:   r;   r<   r!   rO   rU   r>   r   r   r   rL   rL     s    (   r   rL   c                  s:    ] tR tRtR R ltR R ltR R ltRtR	# )
r]   i&  c               rP   rW   r   r	   r
   r   r   Semaphore.__annotate__'  s     ; ;c ;d ;r   c                	s>    \         P                  ! VR 7      V n        R# ))ZvalueN)rh   r]   
_semaphorer[   r\   r   r!   ZSemaphore.__init__'  s    #--E:r   c               r   r   r   r	   r
   r   r   ry   *       " " "r   c                	ro   rC   )rz   r*   r   r    r   r*   ZSemaphore.acquire*      !r   c               r   r   r   r	   r
   r   r   ry   -  r{   r   c                	ro   rC   )rz   r3   r   r    r   r3   ZSemaphore.release-  r|   r   )rz   N)r9   r:   r;   r<   r!   r*   r3   r>   r   r   r   r]   r]   &  s    ;"" "r   r]   c                  s2    ] tR tRtR R ltRR R lltRtR# )	ShieldCancellationi1  c               r   )r   r   r}   r   r	   r
   r   r   ShieldCancellation.__annotate__5  s      - r   c                	rB   rC   r   r   r    r   rD   ZShieldCancellation.__enter__5  rE   r   Nc               r,   r-   r   r	   r
   r   r   r~   8  rF   r   c                	rG   rC   r   r4   r5   r   rH   ZShieldCancellation.__exit__8  rI   r   r   r8   )r9   r:   r;   r<   rD   rH   r>   r   r   r   r}   r}   1  s     r   r}   )Z
__future__r   rh   ZtypesZ_exceptionsr   r   r   r   r   ZNotImplementedErrorr   r   r   r?   rJ   rV   r`   r%   ru   rL   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,