+
    Di*                      a  0 t $ ^ RIHt R7t^ RIt^ 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 ^ RIHt ^RIHt ^RIH t H!t! ]PD                  R88  d   ^ RIH#t# M^ RI$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      t0]R R l4       t1]R  R! l4       t1R" R# lt1]R$R%R&R%R'R%/R( R) ll4       t2]R* R+ l4       t2]R, R- l4       t2R9R$^R&R.R'R./R/ R0 lllt2]R1 R2 l4       t3]R3 R4 l4       t3]+3R5 R6 llt3R# ):    )annotationsAsyncCacheInfoAsyncCacheParametersAsyncLRUCacheWrapperN)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                      ] tR t^8tRtR# )_InitialMissingType N)__name__
__module____qualname____firstlineno____static_attributes__r#       m/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/anyio/functools.pyr"   r"   8   s    r)   r"   initial_missingc                  @    ] tR t^?t$ R]R&   R]R&   R]R&   R]R&   RtR# )	r   inthitsmisses
int | Nonemaxsizecurrsizer#   Nr$   r%   r&   r'   __annotations__r(   r#   r)   r*   r   r   ?   s    
IKMr)   c                  6    ] tR t^Ft$ R]R&   R]R&   R]R&   RtR# )r   r0   r1   booltypedalways_checkpointr#   Nr3   r#   r)   r*   r   r   F   s    Kr)   c                  R    ] tR t^Lt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__M   s     # # < # #r)   c                	    Wn         W n        R # N)_LRUMethodWrapper__wrapper_LRUMethodWrapper__instance)selfr=   r>   s   &&&r*   __init___LRUMethodWrapper.__init__M   s     "r)   c                   V ^8  d   QhRR/# r<   returnr   r#   )r@   s   "r*   rA   rB   Q   s     + +N +r)   c                	6    V P                   P                  4       # rD   )rE   
cache_inforG   s   &r*   rN   _LRUMethodWrapper.cache_infoQ   s    ~~((**r)   c                   V ^8  d   QhRR/# r<   rL   r   r#   )r@   s   "r*   rA   rB   T   s     1 1"6 1r)   c                	6    V P                   P                  4       # rD   )rE   cache_parametersrO   s   &r*   rT   "_LRUMethodWrapper.cache_parametersT   s    ~~..00r)   c                   V ^8  d   QhRR/# r<   rL   Noner#   )r@   s   "r*   rA   rB   W   s     % %T %r)   c                	:    V P                   P                  4        R # rD   )rE   cache_clearrO   s   &r*   rZ   _LRUMethodWrapper.cache_clearW   s    ""$r)   c               $    V ^8  d   QhRRRRRR/# )r<   argsr   kwargsrL   r   r#   )r@   s   "r*   rA   rB   Z   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rD   )rF   rE   )rG   r]   r^   s   &*,r*   __call___LRUMethodWrapper.__call__Z   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'   rH   rN   rT   rZ   r`   r(   r#   r)   r*   r:   r:   L   s"    #+1%F Fr)   r:   c                  b    ] tR t^at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<   funczCallable[P, Awaitable[T]]r1   r0   r7   r6   r8   r#   )r@   s   "r*   rA   !AsyncLRUCacheWrapper.__annotate__c   s2     # #'# # 	#
  #r)   c                	    Wn         ^ V n        ^ V n        Ve   \        V^ 4      MRV n        ^ V n        W0n        W@n        \        W4       R# )r   N)	__wrapped___hits_missesmax_maxsize	_currsize_typed_always_checkpointr   )rG   rf   r1   r7   r8   s   &&&&&r*   rH   AsyncLRUCacheWrapper.__init__c   sF      
+2+>GQD"3t"r)   c                   V ^8  d   QhRR/# rK   r#   )r@   s   "r*   rA   rg   s   s     W WN Wr)   c                	n    \        V P                  V P                  V P                  V P                  4      # rD   )r   rj   rk   rm   rn   rO   s   &r*   rN   AsyncLRUCacheWrapper.cache_infos   s#    djj$,,t~~VVr)   c                   V ^8  d   QhRR/# rR   r#   )r@   s   "r*   rA   rg   v   s     
 
"6 
r)   c                	N    R V P                   RV P                  RV P                  /# r1   r7   r8   rm   ro   rp   rO   s   &r*   rT   %AsyncLRUCacheWrapper.cache_parametersv   s)    t}}T[[!8!8
 	
r)   c                   V ^8  d   QhRR/# rW   r#   )r@   s   "r*   rA   rg   }   s     ; ;T ;r)   c                	    \         P                  R 4      ;p'       d*   VP                  V R 4       ^ ;V n        ;V n        V n        R # R # rD   )r    getpoprj   rk   rn   )rG   caches   & r*   rZ    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.kwargsrL   r   r#   )r@   s   "r*   rA   rg      s&     B BF Bh B1 B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  rxVf_   V ;P$                  ^,          un        VP'                  V4       V P"                  '       d   \)        4       G Rj  xL
  \+        \,        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P1                  RR7       MV ;P.                  ^,          un        V P                  ! V/ VB G Rj  xL
 pVR3Wd&   M:V ;P$                  ^,          un        VP'                  V4       \+        \,        V4      pRRR4      GRj  xL
  V#  EL  \         d$    \        4       p\        P                  T4        ELi ; i  \         d    \        4       ;qeT &    ELi ; i  \         d*    \        \!        T P"                  '       * R7      rYx3Yd&    ELi ; i EL EL 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rD   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rD   r   )r   vals   & r*   r   r      s     1W$s))r   )fast_acquireF)lastr#   )rm   ri   rk   r+   sumitemsro   tuplevaluesr    r|   LookupErrorr   setKeyErrorr   r   rp   rj   move_to_endr   r   r   rn   popitem)	rG   r]   r^   valuekeyr~   cache_entrycached_valuelocks	   &*,      r*   r`   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
	2!,!1L <JJ!OJ##C(&&& l""<((44 + 0 33G!==,4==1P''U'3NNa'N"..???#($;  

a
'',Q- 4"  <"  	'%'E&	'  	6(35K+	6  	2  d&=&="=>   ,1K	2 #  @ 444" s  'M,J:(M,>M,M,.M,M,A	M,)J= >K. 
L ?M,M,M"M,MM,BM"M#AM(M,3M4M,=*K+'M,*K++M,.LM,
LM,0M>M,MM,M,MM,M)	M
M)	!M)	#	M,Nc               $    V ^8  d   QhRRRRRR/# )r<   r>   r?   ownerztype | NonerL   z_LRUMethodWrapper[T]r#   )r@   s   "r*   rA   rg      s$      '2	r)   c                	F    \        W4      p\        W0P                  4       V# rD   )r:   r   ri   )rG   r>   r   r=   s   &&& r*   __get__AsyncLRUCacheWrapper.__get__   s!     $D3w 0 01r)   )ri   rp   rn   rj   rm   rk   ro   rD   )r$   r%   r&   r'   rH   rN   rT   rZ   r`   r   r(   r#   r)   r*   r   r   a   s(    # W
;
BH 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<   r1   r0   r7   r6   r8   r#   )r@   s   "r*   rA   _LRUCacheWrapper.__annotate__   s!     4 4
 44 4D 4r)   c                	*    Wn         W n        W0n        R # rD   rx   )rG   r1   r7   r8   s   &&&&r*   rH   _LRUCacheWrapper.__init__   s    "3r)   c                    V ^8  d   QhRRRR/# r<   rf   z#Callable[P, Coroutine[Any, Any, T]]rL   zAsyncLRUCacheWrapper[P, T]r#   )r@   s   "r*   rA   r      s     ) )7)	#)r)   c               	    R # rD   r#   rG   rf   s   ""r*   r`   _LRUCacheWrapper.__call__   s     &)r)   c                    V ^8  d   QhRRRR/# r<   rf   zCallable[..., T]rL   zfunctools._lru_cache_wrapper[T]r#   )r@   s   "r*   rA   r      s     . .$.	(.r)   c               	    R # rD   r#   r   s   ""r*   r`   r      s     +.r)   c                    V ^8  d   QhRRRR/# )r<   fz6Callable[P, Coroutine[Any, Any, T]] | Callable[..., T]rL   <AsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T]r#   )r@   s   "r*   rA   r      s      P PGP	EPr)   c               	    \        V4      '       d,   \        WP                  V P                  V P                  4      # \
        P                  ! V P                  V P                  R 7      ! V4      # ))r1   r7   )r   r   rm   ro   rp   	functools	lru_cache)rG   r   s   ""r*   r`   r      sS     q!!'==$++t/F/F  ""4==LQOOr)   )rp   rm   ro   N)r$   r%   r&   r'   rH   r   r`   r(   r#   r)   r*   r   r      s;    4
 ) ) . .P Pr)   r   c                    V ^8  d   QhRRRR/# r   r#   )r@   s   "r*   rA   rA           % %
-%%r)   c                   R # rD   r#   rf   s   "r*   r~   r~           "%r)   c                    V ^8  d   QhRRRR/# r   r#   )r@   s   "r*   rA   rA      s     L L  L(G Lr)   c                   R # rD   r#   r   s   "r*   r~   r~      s    ILr)   c                    V ^8  d   QhRRRR/# )r<   rf   z6Callable[..., T] | Callable[P, Coroutine[Any, Any, T]]rL   r   r#   )r@   s   "r*   rA   rA      s     	) 	)
@	)A	)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)r1   )r   r   s   "r*   r~   r~      s     T"4((r)   r1   .r7   r8   c               (    V ^8  d   QhRRRRRRRR/# )r<   r1   r0   r7   r6   r8   rL   z_LRUCacheWrapper[Any]r#   )r@   s   "r*   rA   rA      s,         )- HL  r)   c                    R # rD   r#   rw   s   $$$r*   r   r      s      r)   c                    V ^8  d   QhRRRR/# r   r#   )r@   s   "r*   rA   rA     r   r)   c                   R # rD   r#   r   s   "r*   r   r     r   r)   c                    V ^8  d   QhRRRR/# r   r#   )r@   s   "r*   rA   rA     s     P P$ P,K Pr)   c                   R # rD   r#   r   s   "r*   r   r     s    MPr)   Fc          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r<   rf   z=Callable[P, Coroutine[Any, Any, T]] | Callable[..., T] | Noner1   r0   r7   r6   r8   rL   zTAsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T] | _LRUCacheWrapper[Any]r#   )r@   s   "r*   rA   rA     sD     H H
GH 	H
 H H YHr)   c                  V f   \         \        ,          ! WV4      # \        V 4      '       g   \        R4      h\         \        ,          ! WV4      ! V 4      # )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   )rf   r1   r7   r8   s   "$$$r*   r   r     sI    , |$W5FGGD>>=>>Aw/@A$GGr)   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]rL   r#   )r@   s   "r*   rA   rA   /  s0       	,,
 r)   c                  "   R # 5irD   r#   )r   r   r   s   ""&r*   reducer   .  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]rL   r   r#   )r@   s   "r*   rA   rA   8  s&      ,, 	r)   c                  "   R # 5irD   r#   )r   r   s   ""r*   r   r   7  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]rL   r   r#   )r@   s   "r*   rA   rA   ?  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   ?  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   )      rD   )4__conditional_annotations__
__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    r4   r"   r+   r   r   r:   r   r   r~   r   r   )r   s   @r*   <module>r      s   " "  
 #  % '	 	 	 & ( (w +CLCLcN    	 	 (;'<$ <Z 9 F
 F* i71a4= i iXPwqz P6 
% 
%
 
 L 
 L	) 
   03 OR  
 
 
% 
%
 
 P 
 PH 	H
 H $H H> 
 
 
 
 (7	8 8r)   