
    pT:iM'                       % S SK Jr  SrS SKrS SKrS SKJr  S SKJrJ	r	J
r
JrJrJr  S SKJr  S SKJr  S SKJrJrJrJrJrJrJrJr  S S	KJr  S
SKJr  S
SKJrJ r   \RB                  S:  a  S SKJ"r"  OS SK#J"r"  \" S5      r$\" S5      r%\"" S5      r&\" S5      r'S\(S'    " S S5      r)\)" 5       r*S\(S'    " S S\5      r+ " S S\5      r,\ " S S\\&\$4   5      5       r- " S S\\$   5      r.\    S-S j5       r/\S.S  j5       r/    S/S! jr/\S"S"S"S#.       S0S$ jj5       r0\    S-S% j5       r0\S.S& j5       r0 S1S'S(S(S#.         S2S) jjjr0\        S3S* j5       r1\      S4S+ j5       r1\*4       S5S, jjr1g)6    )annotations)AsyncCacheInfoAsyncCacheParametersAsyncLRUCacheWrappercache	lru_cachereduceN)OrderedDict)AsyncIterable	AwaitableCallable	CoroutineHashableIterable)update_wrapper)iscoroutinefunction)AnyGeneric
NamedTuple	TypedDictTypeVarcastfinaloverload)WeakKeyDictionary   )Lock)RunVar
checkpoint)      )	ParamSpecTSPlru_cache_itemszRunVar[WeakKeyDictionary[AsyncLRUCacheWrapper[Any, Any], OrderedDict[Hashable, tuple[_InitialMissingType, Lock] | tuple[Any, None]]]]c                      \ rS rSrSrg)_InitialMissingType8    N)__name__
__module____qualname____firstlineno____static_attributes__r*       S/var/www/html/aadhar_voter_ocr/venv/lib/python3.13/site-packages/anyio/functools.pyr(   r(   8   s    r0   r(   initial_missingc                  >    \ rS rSr% S\S'   S\S'   S\S'   S\S'   Srg	)
r   ?   inthitsmisses
int | Nonemaxsizecurrsizer*   Nr+   r,   r-   r.   __annotations__r/   r*   r0   r1   r   r   ?   s    
IKMr0   r   c                  4    \ rS rSr% S\S'   S\S'   S\S'   Srg)	r   F   r8   r9   booltypedalways_checkpointr*   Nr;   r*   r0   r1   r   r   F   s    Kr0   r   c                  V    \ rS rSr        S	S jrS
S jrSS jrSS jrSS jrSr	g)r   L   c                    Xl         SU l        SU l        Ub  [        US5      OS U l        SU l        X0l        X@l        [        X5        g Nr   )	__wrapped___hits_missesmax_maxsize	_currsize_typed_always_checkpointr   )selffuncr9   r@   rA   s        r1   __init__AsyncLRUCacheWrapper.__init__N   sF      
+2+>GQD"3t"r0   c                n    [        U R                  U R                  U R                  U R                  5      $ N)r   rG   rH   rJ   rK   rN   s    r1   
cache_infoAsyncLRUCacheWrapper.cache_info^   s#    djj$,,t~~VVr0   c                J    U R                   U R                  U R                  S.$ )Nr9   r@   rA   rJ   rL   rM   rT   s    r1   cache_parameters%AsyncLRUCacheWrapper.cache_parametersa   s#    }}[[!%!8!8
 	
r0   c                    [         R                  S 5      =n(       a(  UR                  U S 5        S=U l        =U l        U l        g g rE   )r&   getpoprG   rH   rK   )rN   r   s     r1   cache_clear AsyncLRUCacheWrapper.cache_clearh   s@    #''--5-IIdD!9::DJ: .r0   c                  #    U R                   S:X  a1  U R                  " U0 UD6I S h  vN nU =R                  S-  sl        U$ UnU(       a%  U[        4[	        UR                  5       S5      -   -  nU R                  (       aG  U[        S U 5       5      -  nU(       a+  U[        4[        S UR                  5        5       5      -   -  n [        R                  5       n XP   n Xd   u  pxUcY  U =R$                  S-  sl        UR'                  U5        U R"                  (       a  [)        5       I S h  vN   [+        [,        U5      $ U IS h  vN   Xd   S   =n[        L a  U =R                  S-  sl        U R                   b*  U R.                  U R                   :  a  UR1                  SS9  OU =R.                  S-  sl        U R                  " U0 UD6I S h  vN nUS 4Xd'   O6U =R$                  S-  sl        UR'                  U5        [+        [,        U5      nS S S 5      IS h  vN   U$  GN! [         a#    [        5       n[        R                  U5         GN|f = f! [         a    [        5       =oeU '    GNf = f! [         a&    [        [!        U R"                  (       + S9pXx4Xd'    GNf = f GN GNg N N! , IS h  vN  (       d  f       W$ = f7f)	Nr   r   r*   c              3  8   #    U  H  n[        U5      v   M     g 7frS   type).0args     r1   	<genexpr>0AsyncLRUCacheWrapper.__call__.<locals>.<genexpr>{   s     3dscd   c              3  8   #    U  H  n[        U5      v   M     g 7frS   rc   )re   vals     r1   rg   rh   }   s     1W$s))ri   )fast_acquireF)last)rJ   rF   rH   r2   sumitemsrL   tuplevaluesr&   r]   LookupErrorr   setKeyErrorr
   r   rM   rG   move_to_endr   r   r#   rK   popitem)	rN   argskwargsvaluekeyr   cache_entrycached_valuelocks	            r1   __call__AsyncLRUCacheWrapper.__call__m   sw    ==A**D;F;;ELLALL  $O%FLLNB(???C;;53d333C)E1Wv}}1W,WWW	'#'')E
	6+K
	2!,!1L <JJ!OJ##C(&& l""<((4 + 0 33G!==,4==1P''U'3NNa'N"..???#($;  

a
'',Q- 4"  <"  	'%'E&	'  	6(35K+	6  	2  d&=&="=>   ,1K	2 #  @ 44" s   &KH,B!KH/  I %I> +AK2J13KJ4KBJ;J7AJ;K%J9&K/)IKIKI;7K:I;;K>,J.*K-J..K4K7J;9K;KKKK)rF   rM   rK   rG   rJ   rH   rL   N)rO   zCallable[..., Awaitable[T]]r9   r8   r@   r?   rA   r?   )returnr   )r   r   )r   None)rw   zP.argsrx   zP.kwargsr   r#   )
r+   r,   r-   r.   rP   rU   rZ   r_   r~   r/   r*   r0   r1   r   r   L   sC    #)# # 	#
  # W
;
Br0   r   c                  h    \ rS rSrSS jr\    S	S j5       r\    S
S j5       r    SS jrSrg)_LRUCacheWrapper   c                (    Xl         X l        X0l        g rS   rY   )rN   r9   r@   rA   s       r1   rP   _LRUCacheWrapper.__init__   s    "3r0   c                   g rS   r*   rN   rO   s     r1   r~   _LRUCacheWrapper.__call__   s     &)r0   c                   g rS   r*   r   s     r1   r~   r      s     +.r0   c                   [        U5      (       a+  [        XR                  U R                  U R                  5      $ [
        R                  " U R                  U R                  S9" U5      $ )N)r9   r@   )r   r   rJ   rL   rM   	functoolsr   )rN   fs     r1   r~   r      sS     q!!'==$++t/F/F  ""4==LQOOr0   )rM   rJ   rL   N)r9   r8   r@   r?   rA   r?   rO   z#Callable[P, Coroutine[Any, Any, T]]r   zAsyncLRUCacheWrapper[P, T]rO   zCallable[..., T]r   zfunctools._lru_cache_wrapper[T])r   z6Callable[P, Coroutine[Any, Any, T]] | Callable[..., T]r   <AsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T])r+   r,   r-   r.   rP   r   r~   r/   r*   r0   r1   r   r      sg    4
 )7)	#) ) .$.	(. .PGP	EPr0   r   c                   g rS   r*   rO   s    r1   r   r           "%r0   c                   g rS   r*   r   s    r1   r   r      s    ILr0   c                    [        SS9" U 5      $ )z
A convenient shortcut for :func:`lru_cache` with ``maxsize=None``.

This is the asynchronous equivalent to :func:`functools.cache`.

N)r9   )r   r   s    r1   r   r      s     T"4((r0   .rX   c                    g rS   r*   rX   s      r1   r   r      s      r0   c                   g rS   r*   r   s    r1   r   r      r   r0   c                   g rS   r*   r   s    r1   r   r      s    MPr0      Fc                  U c  [         [           " XU5      $ [        U 5      (       d  [        S5      e[         [           " XU5      " U 5      $ )az  
An asynchronous version of :func:`functools.lru_cache`.

If a synchronous function is passed, the standard library
:func:`functools.lru_cache` is applied instead.

:param always_checkpoint: if ``True``, every call to the cached function will be
    guaranteed to yield control to the event loop at least once

.. note:: Caches and locks are managed on a per-event loop basis.

z#the first argument must be callable)r   r   callable	TypeErrorr#   )rO   r9   r@   rA   s       r1   r   r      sI    , |$W5FGGD>>=>>Aw/@A$GGr0   c                  #    g 7frS   r*   )functioniterableinitials      r1   r	   r	     s
      	   c                  #    g 7frS   r*   )r   r   s     r1   r	   r	     s
     
 	r   c                 #    Sn[        U[        5      (       ap  UR                  5       nU[        L a(   [	        [
        UR                  5       I Sh  vN 5      nO[	        [
        U5      nU  Sh  vN nU " XV5      I Sh  vN nSnM  [        U[        5      (       a[  [        U5      nU[        L a   [	        [
        [        U5      5      nO[	        [
        U5      nU H  nU " XV5      I Sh  vN nSnM     O[        S5      eU(       d  [        5       I Sh  vN   U$  N! [         a    [        S5      Sef = f N N
 N=! [         a    [        S5      Sef = f Nm ND7f)aX  
Asynchronous version of :func:`functools.reduce`.

:param function: a coroutine function that takes two arguments: the accumulated
    value and the next element from the iterable
:param iterable: an iterable or async iterable
:param initial: the initial value (if missing, the first element of the iterable is
    used as the initial value)

FNz0reduce() of empty sequence with no initial valueTz9reduce() argument 2 must be an iterable or async iterable)
isinstancer   	__aiter__r2   r   r#   	__anext__StopAsyncIterationr   r   iternextStopIterationr   )r   r   r   function_calledasync_itry   elementits           r1   r	   r	   #  sY    " O(M**%%'o%Qh&8&8&: :; G$E% 	#'"522E"O	Hh	'	'(^o%QR) G$EG"522E"O  STT lLE !;% F	#2 & ! F 3 	s   1E D" D 
D" E -E 1D<2E 5E D>1E 4E !E .E/*E EE  D" "D99E <E >E  E EE E r   r   )rO   z6Callable[..., T] | Callable[P, Coroutine[Any, Any, T]]r   r   )r9   r8   r@   r?   rA   r?   r   z_LRUCacheWrapper[Any]rS   )
rO   z=Callable[P, Coroutine[Any, Any, T]] | Callable[..., T] | Noner9   r8   r@   r?   rA   r?   r   zTAsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T] | _LRUCacheWrapper[Any])r   r#   r   zCallable[[T, S], Awaitable[T]]r   zIterable[S] | AsyncIterable[S]r   r#   )r   zCallable[[T, T], Awaitable[T]]r   zIterable[T] | AsyncIterable[T]r   r#   )r   zT | _InitialMissingTyper   z?Callable[[T, T], Awaitable[T]] | Callable[[T, S], Awaitable[T]]r   z?Iterable[T] | Iterable[S] | AsyncIterable[T] | AsyncIterable[S]r   r#   )2
__future__r   __all__r   syscollectionsr
   collections.abcr   r   r   r   r   r   r   inspectr   typingr   r   r   r   r   r   r   r   weakrefr   _core._synchronizationr   lowlevelr   r   version_infor"   typing_extensionsr#   r$   r%   r&   r<   r(   r2   r   r   r   r   r   r   r	   r*   r0   r1   <module>r      s   "  
 #  % '	 	 	 & ( (w +CLCLcN    	 	 (;'<$ <Z 9  b71a4= b bJPwqz P6 
%
-%% 
%
 
 L 
 L	)
@	)A	) 
 s  )- HL   
 
 
%
-%% 
%
 
 P 
 P KOH #H
GH 	H
 H H YH> 
 	,,
  
 
,, 	 
 (7	8 %	8M8M8
 8r0   