+
    Xj.              	        a  0 t $ ^ RIHt R8t^ RIt^ RIHt ^ RIHtH	t	H
t
HtHtHt ^ RIHt ^ R	IHt ^ R
IHtHtHtHtHtHtHtHtHt ^ RIHt ^RIHt ^RIH t  ^RI!H"t"H#t# ]! R4      t$]! R4      t%]! R4      t&]"! R4      t'R](R&    ! R R4      t)])! 4       t*R](R&    ! R R]4      t+ ! R R]4      t, ! R R]]$,          4      t-] ! R R]]&]$3,          4      4       t. ! R R4      t/]R R l4       t0]R  R! l4       t0R" R# lt0]R$R%R&R%R'R%R(R%/R) R* ll4       t1]R+ R, l4       t1]R- R. l4       t1R9R$^R&R/R'R/R(R/R0 R1 lllt1]R2 R3 l4       t2]R4 R5 l4       t2]*3R6 R7 llt2R# ):    )annotationsAsyncCacheInfoAsyncCacheParametersAsyncLRUCacheWrapperN)OrderedDict)AsyncIterable	AwaitableCallable	CoroutineHashableIterable)update_wrapper)iscoroutinefunction)	AnyGeneric
NamedTuple	ParamSpec	TypedDictTypeVarcastfinaloverload)WeakKeyDictionary)current_time)Lock)RunVar
checkpointTSPlru_cache_itemszRunVar[WeakKeyDictionary[AsyncLRUCacheWrapper[Any, Any], OrderedDict[Hashable, tuple[_InitialMissingType, Lock, float | None] | tuple[Any, None, float | None]]]]c                      ] tR t^8tRtR# )_InitialMissingType N)__name__
__module____qualname____firstlineno____static_attributes__r$       k   /Users/wind/Downloads/Coruna-main学习资料A/backend/venv/lib/python3.14/site-packages/anyio/functools.pyr#   r#   8   s    r*   r#   initial_missingc                  J    ] tR t^?t$ R]R&   R]R&   R]R&   R]R&   R]R&   RtR	# )
r   inthitsmisses
int | Nonemaxsizecurrsizettlr$   Nr%   r&   r'   r(   __annotations__r)   r$   r*   r+   r   r   ?   s    
IKM	Or*   c                  @    ] tR t^Gt$ R]R&   R]R&   R]R&   R]R&   RtR# )	r   r1   r2   booltypedalways_checkpointr4   r$   Nr5   r$   r*   r+   r   r   G   s    K	Or*   c                  R    ] tR t^NtR R ltR R ltR R ltR R ltR	 R
 ltRt	R# )_LRUMethodWrapperc                    V ^8  d   QhRRRR/# )   wrapperzAsyncLRUCacheWrapper[..., T]instanceobjectr$   )formats   "r+   __annotate___LRUMethodWrapper.__annotate__O   s     # # < # #r*   c                	    Wn         W n        R # N)_LRUMethodWrapper__wrapper_LRUMethodWrapper__instance)selfr?   r@   s   &&&r+   __init___LRUMethodWrapper.__init__O   s     "r*   c                   V ^8  d   QhRR/# r>   returnr   r$   )rB   s   "r+   rC   rD   S   s     + +N +r*   c                	6    V P                   P                  4       # rF   )rG   
cache_inforI   s   &r+   rP   _LRUMethodWrapper.cache_infoS   s    ~~((**r*   c                   V ^8  d   QhRR/# r>   rN   r   r$   )rB   s   "r+   rC   rD   V   s     1 1"6 1r*   c                	6    V P                   P                  4       # rF   )rG   cache_parametersrQ   s   &r+   rV   "_LRUMethodWrapper.cache_parametersV   s    ~~..00r*   c                   V ^8  d   QhRR/# r>   rN   Noner$   )rB   s   "r+   rC   rD   Y   s     % %T %r*   c                	:    V P                   P                  4        R # rF   )rG   cache_clearrQ   s   &r+   r\   _LRUMethodWrapper.cache_clearY   s    ""$r*   c               $    V ^8  d   QhRRRRRR/# )r>   argsr   kwargsrN   r   r$   )rB   s   "r+   rC   rD   \   s&     F FC F3 F1 Fr*   c                	   "   V P                   f   V P                  ! V/ VB G R j  xL
 # V P                  ! V P                   .VO5/ VB G R j  xL
 #  L, L5irF   )rH   rG   )rI   r_   r`   s   &*,r+   __call___LRUMethodWrapper.__call__\   sN     ??"8888^^DOOEdEfEEE 9Es!   $AA'AAAA)
__instance	__wrapperN)
r%   r&   r'   r(   rJ   rP   rV   r\   rb   r)   r$   r*   r+   r<   r<   N   s"    #+1%F Fr*   r<   c                  b    ] tR t^ctR R ltR R ltR R ltR R ltR	 R
 ltRR R llt	Rt
R# )r   c          
     ,    V ^8  d   QhRRRRRRRRRR/# )	r>   funczCallable[P, Awaitable[T]]r2   r1   r9   r8   r:   r4   r$   )rB   s   "r+   rC   !AsyncLRUCacheWrapper.__annotate__e   s<     # #'# # 	#
  # #r*   c                	    Wn         ^ V n        ^ V n        Ve   \        V^ 4      MRV n        ^ V n        W0n        W@n        WPn        \        W4       R# )r   N)
__wrapped___hits_missesmax_maxsize	_currsize_typed_always_checkpoint_ttlr   )rI   rh   r2   r9   r:   r4   s   &&&&&&r+   rJ   AsyncLRUCacheWrapper.__init__e   sK      
+2+>GQD"3	t"r*   c                   V ^8  d   QhRR/# rM   r$   )rB   s   "r+   rC   ri   w   s     
 
N 
r*   c                	    \        V P                  V P                  V P                  V P                  V P
                  4      # rF   )r   rl   rm   ro   rp   rs   rQ   s   &r+   rP   AsyncLRUCacheWrapper.cache_infow   s.    JJdmmT^^TYY
 	
r*   c                   V ^8  d   QhRR/# rT   r$   )rB   s   "r+   rC   ri   |   s     
 
"6 
r*   c                	f    R V P                   RV P                  RV P                  RV P                  /# r2   r9   r:   r4   ro   rq   rr   rs   rQ   s   &r+   rV   %AsyncLRUCacheWrapper.cache_parameters|   s2    t}}T[[!8!8499	
 	
r*   c                   V ^8  d   QhRR/# rY   r$   )rB   s   "r+   rC   ri      s     ; ;T ;r*   c                	    \         P                  R 4      ;p'       d*   VP                  V R 4       ^ ;V n        ;V n        V n        R # R # rF   )r!   getpoprl   rm   rp   )rI   caches   & r+   r\    AsyncLRUCacheWrapper.cache_clear   s@    #''--5-IIdD!9::DJ: .r*   c               $    V ^8  d   QhRRRRRR/# )r>   r_   zP.argsr`   zP.kwargsrN   r   r$   )rB   s   "r+   rC   ri      s&     O OF Oh O1 Or*   c                	  "   V P                   ^ 8X  d6   V P                  ! V/ VB G Rj  xL
 pV ;P                  ^,          un        V# TpV'       d.   V\        3\	        VP                  4       R4      ,           ,          pV P                  '       d   T\        ;QJ d    . R V 4       F  NK  	  5M! R V 4       4      ,          pV'       d\   T\        3\        ;QJ d"    . R VP                  4        4       F  NK  	  5M! R VP                  4        4       4      ,           ,          p \        P                  4       p WP,          p Wd,          w  rxp	Vf   V	eR   \%        4       V	8  dC   V ;P&                  ^,          un        \        \!        V P"                  '       * R7      RrpWxV	3Wd&   M^V ;P(                  ^,          un        VP+                  V4       V P"                  '       d   \-        4       G Rj  xL
  \/        \0        V4      # T;_uu_4       GRj  xL
  Wd,          ^ ,          ;p\        J d   V ;P                  ^,          un        V P                   e/   V P&                  V P                   8  d   VP3                  RR7       MV ;P&                  ^,          un        V P                  ! V/ VB G Rj  xL
 pV P4                  e   \%        4       V P4                  ,           MRp	VRV	3Wd&   M:V ;P(                  ^,          un        VP+                  V4       \/        \0        V4      pRRR4      GRj  xL
  V#  EL  \         d$    \        4       p\        P                  T4        EL/i ; i  \         d    \        4       ;qeT &    ELFi ; i  \         d-    \        \!        T P"                  '       * R7      RrpYxT	3Yd&    ELti ; i EL EL EL L  + GRj  xL 
 '       g   i     X# ; i5i)r   Nc              3  8   "   T F  p\        V4      x  K  	  R # 5irF   type).0args   & r+   	<genexpr>0AsyncLRUCacheWrapper.__call__.<locals>.<genexpr>   s     3dscd   c              3  8   "   T F  p\        V4      x  K  	  R # 5irF   r   )r   vals   & r+   r   r      s     1W$s))r   )fast_acquireF)lastr$   )ro   rk   rm   r,   sumitemsrq   tuplevaluesr!   r   LookupErrorr   setKeyErrorr   r   rr   r   rp   rl   move_to_endr   r   r   popitemrs   )
rI   r_   r`   valuekeyr   cache_entrycached_valuelock
expires_ats
   &*,       r+   rb   AsyncLRUCacheWrapper.__call__   s    ==A**D;F;;ELLALL  $O%FLLNB(???C;;;553d3553d333C)EE1Wv}}1WEE1Wv}}1W,WWW	'#'')E
	6+K
		>-8-=*L
 <%,.J*F!##$*A*A&AB %/
 $0z#A  

a
'',***$,&&A|,,44 + 0 33G!==,4==1P''U'3NNa'N"..???26))2GLNTYY.T  $)$
#:  

a
'',Q-% 4( Y <"  	'%'E&	'  	6(35K+	6  	>  d&=&="=> !+L
  ,:=K	>. '  @ 444( s  'O2L<(O2>O2O2.O2O2A	O2)L? >M0 N BO2'O24O
5"O2OO2BO8O9A1O*O25O6O2?*M-)O2,M--O20N	O2NO23OO2OO2O2OO2O/	O
O/	'O/	)	O2Nc               $    V ^8  d   QhRRRRRR/# )r>   r@   rA   ownerztype | NonerN   z_LRUMethodWrapper[T]r$   )rB   s   "r+   rC   ri      s$      '2	r*   c                	F    \        W4      p\        W0P                  4       V# rF   )r<   r   rk   )rI   r@   r   r?   s   &&& r+   __get__AsyncLRUCacheWrapper.__get__   s!     $D3w 0 01r*   )rk   rr   rp   rl   ro   rm   rs   rq   rF   )r%   r&   r'   r(   rJ   rP   rV   r\   rb   r   r)   r$   r*   r+   r   r   c   s'    #$


;
Ob r*   c                  Z    ] tR t^tR R lt]R R l4       t]R R l4       tR R ltR	tR
# )_LRUCacheWrapperc               (    V ^8  d   QhRRRRRRRR/# )r>   r2   r1   r9   r8   r:   r4   r$   )rB   s   "r+   rC   _LRUCacheWrapper.__annotate__   s,      !*.CGNXr*   c                	6    Wn         W n        W0n        W@n        R # rF   r{   )rI   r2   r9   r:   r4   s   &&&&&r+   rJ   _LRUCacheWrapper.__init__   s      "3	r*   c                    V ^8  d   QhRRRR/# r>   rh   z#Callable[P, Coroutine[Any, Any, T]]rN   zAsyncLRUCacheWrapper[P, T]r$   )rB   s   "r+   rC   r      s     ) )7)	#)r*   c               	    R # rF   r$   rI   rh   s   ""r+   rb   _LRUCacheWrapper.__call__   s     &)r*   c                    V ^8  d   QhRRRR/# r>   rh   zCallable[..., T]rN   zfunctools._lru_cache_wrapper[T]r$   )rB   s   "r+   rC   r      s     . .$.	(.r*   c               	    R # rF   r$   r   s   ""r+   rb   r      s     +.r*   c                    V ^8  d   QhRRRR/# )r>   fz6Callable[P, Coroutine[Any, Any, T]] | Callable[..., T]rN   z<AsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T]r$   )rB   s   "r+   rC   r      s      P PGP	EPr*   c               	    \        V4      '       d7   \        WP                  V P                  V P                  V P
                  4      # \        P                  ! V P                  V P                  R 7      ! V4      # ))r2   r9   )r   r   ro   rq   rr   rs   	functools	lru_cache)rI   r   s   ""r+   rb   r      sY     q!!'==$++t/F/F		  ""4==LQOOr*   )rr   ro   rs   rq   N)r%   r&   r'   r(   rJ   r   rb   r)   r$   r*   r+   r   r      s;     ) ) . .P Pr*   r   c                    V ^8  d   QhRRRR/# r   r$   )rB   s   "r+   rC   rC          % %
-%%r*   c                   R # rF   r$   rh   s   "r+   r   r           "%r*   c                    V ^8  d   QhRRRR/# r   r$   )rB   s   "r+   rC   rC     s     L L  L(G Lr*   c                   R # rF   r$   r   s   "r+   r   r     s    ILr*   c                    V ^8  d   QhRRRR/# )r>   rh   z:Callable[..., Any] | Callable[P, Coroutine[Any, Any, Any]]rN   r   r$   )rB   s   "r+   rC   rC   
  s     ) )J )RU )r*   c               &    \        RR7      ! V 4      # )z
A convenient shortcut for :func:`lru_cache` with ``maxsize=None``.

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

N)r2   )r   r   s   "r+   r   r   
  s     T"4((r*   r2   .r9   r:   r4   c          
     ,    V ^8  d   QhRRRRRRRRRR/# )	r>   r2   r1   r9   r8   r:   r4   rN   r   r$   )rB   s   "r+   rC   rC     s<        	
 
 r*   c                    R # rF   r$   rz   s   $$$$r+   r   r     s     r*   c                    V ^8  d   QhRRRR/# r   r$   )rB   s   "r+   rC   rC     r   r*   c                   R # rF   r$   r   s   "r+   r   r     r   r*   c                    V ^8  d   QhRRRR/# r   r$   )rB   s   "r+   rC   rC   %  s     P P$ P,K Pr*   c                   R # rF   r$   r   s   "r+   r   r   $  s    MPr*   Fc               0    V ^8  d   QhRRRRRRRRRRR	R
/# )r>   rh   zCCallable[..., Coroutine[Any, Any, Any]] | Callable[..., Any] | Noner2   r1   r9   r8   r:   r4   rN   r   r$   )rB   s   "r+   rC   rC   (  sN     J J
MJ 	J
 J J 
J 	Jr*   c              ~    V f   \        WW44      # \        V 4      '       g   \        R4      h\        WW44      ! V 4      # )a  
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
:param ttl: time in seconds after which to invalidate cache entries

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

z#the first argument must be callable)r   callable	TypeError)rh   r2   r9   r:   r4   s   "$$$$r+   r   r   (  s?    , |0AGGD>>=>>G,=CDIIr*   c               (    V ^8  d   QhRRRRRRRR/# )r>   initialr   functionzCallable[[T, S], Awaitable[T]]iterablezIterable[S] | AsyncIterable[S]rN   r$   )rB   s   "r+   rC   rC   H  s0       	,,
 r*   c                  "   R # 5irF   r$   )r   r   r   s   ""&r+   reducer   G  s
      	   c               $    V ^8  d   QhRRRRRR/# )r>   r   zCallable[[T, T], Awaitable[T]]r   zIterable[T] | AsyncIterable[T]rN   r   r$   )rB   s   "r+   rC   rC   Q  s&      ,, 	r*   c                  "   R # 5irF   r$   )r   r   s   ""r+   r   r   P  s
     
 	r   c               (    V ^8  d   QhRRRRRRR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]rN   r   r$   )rB   s   "r+   rC   rC   X  s0     8 8 %	8M8M8
 8r*   c                 "   Rp\        V\        4      '       ds   VP                  4       pV\        J d)    \	        \
        VP                  4       G Rj  xL
 4      pM\	        \
        V4      pV  Rj  xL
  pV ! WV4      G Rj  xL
 pRpK  \        V\        4      '       d]   \        V4      pV\        J d    \	        \
        \        V4      4      pM\	        \
        V4      pV F  pV ! WV4      G Rj  xL
 pRpK  	  M\        R4      hV'       g   \        4       G Rj  xL
  V#  L  \         d    \        R4      Rhi ; i L LDL?  \         d    \        R4      Rhi ; i Lp LF5i)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__r,   r   r   	__anext__StopAsyncIterationr   r   iternextStopIterationr   )r   r   r   function_calledasync_itr   elementits   ""&     r+   r   r   X  s^    " 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   3E(D( D&
D( E(/E3E4E7E(E3E(9E	 !E(3E$4E(E(E& E(&D( (E  E(EE(E(	E!!E(&E()r   r   r   r   r   r   rF   )3__conditional_annotations__
__future__r   __all__r   collectionsr   collections.abcr   r	   r
   r   r   r   r   inspectr   typingr   r   r   r   r   r   r   r   r   weakrefr   _core._eventloopr   _core._synchronizationr   lowlevelr   r   r   r   r    r!   r6   r#   r,   r   r   r<   r   r   r   r   r   )r   s   @r+   <module>r      s   " "  #  % '
 
 
 & * ( (CLCLcN   	 		 	 (;'<$ <Z 9 F
 F* {71a4= { {|P P< 
% 
%
 
 L 
 L) 
  "	
  
 
% 
%
 
 P 
 PJ 	J
 J $J J J> 
 
 
 
 (7	8 8r*   