Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
functools.cpython-313.pyc119 linesDownload Raw Back to __pycache__
1�

2�j,/��@�%SSKJr SrSSKrSSKrSSKJr SSKJrJ	r	J3r4JrJrJ
r
 SSKJr SSKJr SSKJrJrJrJrJrJrJrJr SS	KJr S5SKJr S6SKJr S7S
K J!r!J"r" \RFS:�aSSKJ$r$ OSSK%J$r$ \"S5r&\"S5r'\$"S5r(\!"S5r)S\*S'"SS5r+\+"5r,S\*S'"SS\5r-"SS\5r."SS\\&5r/\"SS\\(\&455r0"S S!\\&5r1\S0S"j5r2\S1S#j5r2S2S$jr2\S%S%S%S%S&.S3S'jj5r3\S0S(j5r3\S1S)j5r3S4S*S+S+SS&.S5S,jjjr3\S6S-j5r4\S7S.j5r4\,4S8S/jjr4g)9�)�annotations)�AsyncCacheInfo�AsyncCacheParameters�AsyncLRUCacheWrapper�cache�	lru_cache�reduceN)�OrderedDict)�
AsyncIterable�	Awaitable�Callable�	Coroutine�Hashable�Iterable)�update_wrapper)�iscoroutinefunction)�Any�Generic�8NamedTuple�	TypedDict�TypeVar�cast�final�overload)�WeakKeyDictionary�)�current_time)�Lock)�RunVar�9checkpoint)��)�	ParamSpec�T�S�P�lru_cache_itemsz�RunVar[WeakKeyDictionary[AsyncLRUCacheWrapper[Any, Any], OrderedDict[Hashable, tuple[_InitialMissingType, Lock, float | None] | tuple[Any, None, float | None]]]]c��\rSrSrSrg)�_InitialMissingType�=�N)�__name__�10__module__�__qualname__�__firstlineno__�__static_attributes__r+��UD:\code\apps\devtools\python\user_packages\Python313\site-packages\anyio/functools.pyr)r)=s��r1r)�initial_missingc�H�\rSrSr%S\S'S\S'S\S'S\S'S\S'S	rg11)r�D�int�hits�misses�12int | None�maxsize�currsize�ttlr+N�r,r-r.r/�__annotations__r0r+r1r2rrDs��13
�I��K�
���M�	�Or1rc�>�\rSrSr%S\S'S\S'S\S'S\S'Srg	)14r�Lr9r:�bool�typed�always_checkpointr<r+Nr=r+r1r2rrLs��
���K���	�Or1rc�F�\rSrSrS	SjrS15SjrSSjrSSjrS
SjrSr	g)�_LRUMethodWrapper�Sc��XlX lg�N)�_LRUMethodWrapper__wrapper�_LRUMethodWrapper__instance)�self�wrapper�instances   r2�__init__�_LRUMethodWrapper.__init__Ts�� ��"�r1c�6�URR5$rH)rI�16cache_info�rKs r2rQ�_LRUMethodWrapper.cache_infoXs���~�~�(�(�*�*r1c�6�URR5$rH)rI�cache_parametersrRs r2rU�"_LRUMethodWrapper.cache_parameters[s���~�~�.�.�0�0r1c�8�URR5 grH)rI�cache_clearrRs r2rX�_LRUMethodWrapper.cache_clear^s�����"�"�$r1c��# �URcUR"U0UD6IShv�N$UR"UR/UQ70UD6IShv�N$N,N7frH)rJrI)rK�args�kwargss   r2�__call__�_LRUMethodWrapper.__call__asN����?�?�"�����8��8�8�8��^�^�D�O�O�E�d�E�f�E�E�E�9�E�s!�#A�A�'A�
A�A�A)�17__instance�	__wrapperN)rLzAsyncLRUCacheWrapper[..., T]rM�object��returnr�rcr�rc�None)r[rr\rrcr$)18r,r-r.r/rNrQrUrXr]r0r+r1r2rErESs��#�+�1�%�Fr1rEc�t�\rSrSrS19SjrSSjrSSjrS
SjrSSjrSSSjjr	S	r20g)r�hc��XlSUlSUlUb[US5OSUlSUlX0lX@lXPl[X5 g�Nr)21�__wrapped__�_hits�_misses�max�_maxsize�	_currsize�_typed�_always_checkpoint�_ttlr)rK�funcr:rBrCr<s      r2rN�AsyncLRUCacheWrapper.__init__jsK�� ����22����+2�+>��G�Q��D��
������"3���	��t�"r1c��[URURURURUR235$rH)rrlrmrorprsrRs r2rQ�AsyncLRUCacheWrapper.cache_info|s.����J�J����d�m�m�T�^�^�T�Y�Y�24�	25r1c�`�URURURURS.$)N�r:rBrCr<�rorqrrrsrRs r2rU�%AsyncLRUCacheWrapper.cache_parameters�s*���}�}��[�[�!%�!8�!8��9�9�	26�	27r1c��[RS5=n(a(URUS5 S=Ul=UlUlggrj)r'�get�poprlrmrp)rKrs  r2rX� AsyncLRUCacheWrapper.cache_clear�s@��#�'�'��-�-�5�-��I�I�d�D�!�9:�:�D�J�:�����.r1c��# �URS:Xa1UR"U0UD6IShv�NnU=RS-
slU$UnU(a%U[4[	UR5S5--
nUR(aGU[SU55-
nU(a+U[4[SUR555--
n[R5nXPnXdupxn	Uc�U	bI[%5U	:�a;U=R&S-sl[[!UR"(+S9Sp�nXxU	4Xd'OYU=R(S-
slUR+U5 UR"(a[-5IShv�N [/[0U5$UIShv�N XdS=n[La�U=RS-
slURb*UR&UR:�aUR3SS9 OU=R&S-
slUR"U0UD6IShv�NnUR4b[%5UR4-OSn	USU	4Xd'O6U=R(S-
slUR+U5 [/[0U5nSSS5IShv�N U$GNx![a# [5n[RU5 GN�f=f![a [5=oeU'GN28f=f![a) [[!UR"(+S9Sp�nXxU	4Xd'GN8f=fGN�GN�GN	N�!,IShv�N(df   W$=f7f)	Nrrr+c3�8# �UHn[U5v� M g7frH��type)�.0�args  r2�	<genexpr>�0AsyncLRUCacheWrapper.__call__.<locals>.<genexpr>�s���3�d�s��c���d���c3�8# �UHn[U5v� M g7frHr�)r��vals  r2r�r��s���1W���$�s�)�)��r�)�fast_acquireF)�last)rorkrmr3�sum�itemsrq�tuple�valuesr'r}�LookupErrorr�set�KeyErrorr29rrrrrprl�move_to_endr rr$�popitemrs)30rKr[r\�value�keyr�cache_entry�cached_value�lock�31expires_ats32          r2r]�AsyncLRUCacheWrapper.__call__�s�����=�=�A���*�*�D�;�F�;�;�E��L�L�A��L��L� $����O�%��F�L�L�N�B�(?�?�?�C��;�;��5�3�d�3�3�3�C����)�E�1W�v�}�}��1W�,W�W�W��	'�#�'�'�)�E�33	6��+�K�34		>�-8�-=�*�L�35��<��%�,�.�J�*F����!�#��#��$�*A�*A�&A�B��%/��36$0�z�#A�� ��37�38�a��39��'�'��,��*�*�$�,�&�&��A�|�,�,��4� +� 0�� 3�3���G�����!���=�=�,����4�=�=�1P��'�'�U�'�3��N�N�a�'�N�"�.�.��?��?�?��26�)�)�2G�L�N�T�Y�Y�.�T��$)�$�40�#:�� ��41�42�a��43��'�'��,��Q��-��%�4�(��Y<��"�	'�%�'�E�����&�	'���	6�(3�
�5�K��+�	6���	>� ��d�&=�&=�"=�>��!+�L�44 ,�:�=�K��	>��.'��@��4�4�(��s��&M�J �B!M�J#� K�%K2�,BM�?L(�M�L+�M�BL3�%L.�&A(L3�M�L1�M�#)K�M�K�M�K/�+M�.K/�/M�2/L%�!M�$L%�%M�+M�.L3�1M�3M�9L<�:M�MNc�F�[X5n[X0R5 U$rH)rErrk)rKrM�ownerrLs    r2�__get__�AsyncLRUCacheWrapper.__get__�s!��$�D�3���w� 0� 0�1��r1)rkrrrprlrormrsrq)45rtzCallable[P, Awaitable[T]]r:r9rBrArCrAr<r9rbrdre)r[zP.argsr\zP.kwargsrcr$rH)rMrar�ztype | Nonercz_LRUMethodWrapper[T])r,r-r.r/rNrQrUrXr]r�r0r+r1r2rrhst��#�'�#��#��	#�46 �#��
#�$47�4849�;�50O�d6:����'2��	��r1rc�x�\rSrSrSSjr\S	Sj5r\S51Sj5rSSjrSrg)�_LRUCacheWrapper��c�4�XlX lX0lX@lgrHrz)rKr:rBrCr<s     r2rN�_LRUCacheWrapper.__init__�s�� �
���"3���	r1c��grHr+�rKrts  r2r]�_LRUCacheWrapper.__call__�s��&)r1c��grHr+r�s  r2r]r��s��+.r1c���[U5(a6[XRURURUR525$[R"URURS9"U5$)N)r:rB)rrrorqrrrs�	functoolsr)rK�fs  r2r]r��sY���q�!�!�'��=�=�$�+�+�t�/F�/F��	�	��
��"�"�4�=�=����L�Q�O�Or1)rrrorsrqN)r:r9rBrArCrAr<r9�rtz#Callable[P, Coroutine[Any, Any, T]]rczAsyncLRUCacheWrapper[P, T]�rtzCallable[..., T]rczfunctools._lru_cache_wrapper[T])r�z6Callable[P, Coroutine[Any, Any, T]] | Callable[..., T]rc�<AsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T])r,r-r.r/rNrr]r0r+r1r2r�r��s����!��*.��CG��NX���)�7�)�	#�)��)��.�$�.�	(�.��.�P�G�P�	E�Pr1r�c��grHr+�rts r2rr���"%r1c��grHr+r�s r2rrs��ILr1c� �[SS9"U5$)z�53A convenient shortcut for :func:`lru_cache` with ``maxsize=None``.54 55This is the asynchronous equivalent to :func:`functools.cache`.56 57N)r:)rr�s r2rrs���T�"�4�(�(r1.ryc��grHr+rys    r2rrs�� r1c��grHr+r�s r2rr%r�r1c��grHr+r�s r2rr+s��MPr1�Fc��Uc[["XX45$[U5(d[S5e[["XX45"U5$)a�58An asynchronous version of :func:`functools.lru_cache`.59 60If a synchronous function is passed, the standard library61:func:`functools.lru_cache` is applied instead.62 63:param always_checkpoint: if ``True``, every call to the cached function will be64    guaranteed to yield control to the event loop at least once65:param ttl: time in seconds after which to invalidate cache entries66 67.. note:: Caches and locks are managed on a per-event loop basis.68 69z#the first argument must be callable)r�r�callable�	TypeErrorr$)rtr:rBrCr<s     r2rr/sI��0�|���$�W�5F�L�L��D�>�>��=�>�>��A��w�/@�F�t�L�Lr1c��# �g7frHr+)�function�iterable�initials   r2r	r	Ps70���	���c��# �g7frHr+)r�r�s  r2r	r	Ys71���72	�r�c���# �Sn[U[5(apUR5nU[La([	[73UR
5IShv�N5nO[	[74U5nUShv�NnU"XV5IShv�NnSnM[U[5(a[[U5nU[La[	[75[U55nO[	[76U5nUHnU"XV5IShv�NnSnM O[S5eU(d[5IShv�N U$N�![a
 [S5Sef=fN�N�77N=![a
 [S5Sef=fNmND7f)aX78Asynchronous version of :func:`functools.reduce`.79 80:param function: a coroutine function that takes two arguments: the accumulated81    value and the next element from the iterable82:param iterable: an iterable or async iterable83:param initial: the initial value (if missing, the first element of the iterable is84    used as the initial value)85 86FNz0reduce() of empty sequence with no initial valueTz9reduce() argument 2 must be an iterable or async iterable)�87isinstancer�	__aiter__r3rr$�	__anext__�StopAsyncIterationr�r�iter�next�
StopIterationr )r�r�r��function_called�async_itr��element�its        r2r	r	asY���"�O��(�M�*�*��%�%�'���o�%�
��Q�h�&8�&8�&:� :�;����G�$�E�%�	#�'�"�5�2�2�E�"�O�	�H�h�	'�	'�
�(�^���o�%�
��Q��R��)����G�$�E��G�"�5�2�2�E�"�O���S�T�T���l����L�E!;��%�
��F����
��	#�2�&��!�
��F����
��3�	�s��1E �D"�D 88�D"�E �-E�1D<�2E�5E �D>�1E �4E�
!E �.E�/*E �E�E � D"�"D9�9E �<E�>E �E �E�E �E r�r�)rtz6Callable[..., T] | Callable[P, Coroutine[Any, Any, T]]rcr�)89r:r9rBrArCrAr<r9rcz_LRUCacheWrapper[Any]rH)rtz=Callable[P, Coroutine[Any, Any, T]] | Callable[..., T] | Noner:r9rBrArCrAr<r9rczTAsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T] | _LRUCacheWrapper[Any])r�r$r�zCallable[[T, S], Awaitable[T]]r�zIterable[S] | AsyncIterable[S]rcr$)r�zCallable[[T, T], Awaitable[T]]r�zIterable[T] | AsyncIterable[T]rcr$)r�zT | _InitialMissingTyper�z?Callable[[T, T], Awaitable[T]] | Callable[[T, S], Awaitable[T]]r�z?Iterable[T] | Iterable[S] | AsyncIterable[T] | AsyncIterable[S]rcr$)5�90__future__r�__all__r��sys�collectionsr91�collections.abcrrr
rrrr�inspectr�typingrrrrrrrr�weakrefr�_core._eventloopr�_core._synchronizationr�lowlevelrr �version_infor#�typing_extensionsr$r%r&r'r>r)r3rrrErr�rrr	r+r1r2�<module>r�s���"����92�#���%�'�	�	�	�&�*�(�(����w�� �+��C�L���C�L��
�c�N������	�	�	�	�(;�'<��$�<��Z���9��F���93�F�*�{�7�1�a�4�=�{��{�|P�w�q�z�P�<94�%�95-�%��%�96�%�9798�L�99�L�	)�100@�	)�A�	)�101���!�� �
� �� ��	 �102103� ��
 �104� �105�%�106-�%��%�107�%�108109�P�110�P�KO�M���#��M�111G�M��	M�112�M��
M�113�M�Y�M�B114���	�,��,��115��116��117��,��,���	�118��(7�	8�%�	8�M�8�M�8�119�8r1
codekingpro/portable-devtools · Team Ai