codekingpro/portable-devtools
114k
1�
2 �j�3 � �^ � S r SSKrSSKJr SSKJr SS/0r/ SQr " S S4\5 r S r5\ r\6r g) z�7Asynchronous progressbar decorator for iterators.8Includes a default `range` iterator printing to `stderr`.9 10Usage:11>>> from tqdm.asyncio import trange, tqdm12>>> async for i in trange(10):13... ...14� N)� version_info� )�tqdmz github.com/� casperdcl)� tqdm_asyncio�taranger �trangec �z ^ � \ rS rSrSrS U 4S jjrS rS rS r\ SSSS.S j5 r15\ SSSS.S16 j5 r S r U =r
$ )
r � z(17Asynchronous-friendly version of tqdm.18Nc �4 >� [ TU ] " U/UQ70 UD6 SU l Uby [ US5 ( a UR U l SU l g [ US5 ( a UR U l g [ U5 U l U R R U l g g )NF� __anext__T�__next__) �super�__init__�iterable_awaitable�hasattrr
�
iterable_nextr �iter�iterable_iterator)�self�iterable�args�kwargs� __class__s ��RD:\code\apps\devtools\python\user_packages\Python313\site-packages\tqdm/asyncio.pyr �tqdm_asyncio.__init__ s� �� �
����3�D�3�F�3�"'�� � � ��x��-�-�%-�%7�%7��"�*.��'���:�.�.�%-�%6�%6��"�)-�h� ��&�%)�%;�%;�%D�%D��"� � c � � U $ �N� )r s r � __aiter__�tqdm_asyncio.__aiter__$ s � �� r c � �$ # � U R ( a U R 5 I S h v�N nOU R 5 nU R 5 U$ N'! [ a U R 5 [19 e[ a U R 5 e f = f7fr )r r �update�
StopIteration�close�StopAsyncIteration�
BaseException)r �ress r r
�tqdm_asyncio.__anext__' sx � � � ��&�&� � .� .� 0�0���(�(�*�� �K�K�M��J� 1��20 � %� �J�J�L�$� $� � � �J�J�L� � �s, �B�$A �A�&A �B�A �;B
�
Bc �: � U R R " U0 UD6$ r )r �send)r r r s r r, �tqdm_asyncio.send6 s � ��}�}�!�!�4�2�6�2�2r ��loop�timeout�totalc + � # � Uc [ U5 n0 n[ SS S: a X&S' U " [ R " U4SU0UD64SU0UD6 Sh v�N g N7f)z%21Wrapper for `asyncio.as_completed`.22N� )� �23 r/ r0 r1 )�lenr �asyncio� as_completed)�cls�fsr/ r0 r1 � tqdm_kwargsr s r r8 �tqdm_asyncio.as_completed9 si � � �24 �=���G�E��� ��� �g� %� !�6�N��w�+�+�B�J��J�6�J� 3� "�3�&1�3� 3� 3�s �AA� A�25Ac � � # � S n[ U5 VVs/ s H
u pxU" Xx5 PM n nnU R " U 4XUS.UD6 Vs/ s H o�I Sh v�N PM n26n[ U275 V Vs/ s H u p�UPM snn $ s snnf N0s snf s snn f 7f)z 28Wrapper for `asyncio.gather`.29c � �$ # � XI S h v�N 4$ N7fr r )�i�fs r �wrap_awaitable�+tqdm_asyncio.gather.<locals>.wrap_awaitableK s � � ��g�:� �g�s ���r. N)� enumerater8 �sorted) r9 r/ r0 r1 r: r; rA r? r@ �ifsr) �_s r �gather�tqdm_asyncio.gatherF s� � � �30 � 1:�"�
�>�
���~�a�#�
��>� #� 0� 0�� !M�4�7<�!M�@K�!M� N� !M�1�w�w� !M�� N� $�S�k�*�k�d�a��k�*�*�� ?��� N��*�s? �B �A8�B �31B �
A>32�B �B �&B�433B �>B � B )r r r r )�__name__�34__module__� __qualname__�__firstlineno__�__doc__r r! r
r, � classmethodr8 rG �__static_attributes__�
__classcell__)r s @r r r sS �� �� E��
� 3� �&*�D�� 353� �363� �$(�$�d� 37+� �38+r r c �& � [ [ U 6 40 UD6$ )z=39A shortcut for `tqdm.asyncio.tqdm(range(*args), **kwargs)`.40)r �range)r r s r r r T s � � ��t� � /�� /�/r ) rM r7 �sysr �stdr �std_tqdm�41__author__�__all__r r r r r r �<module>rX sD ��� � � !��k�]�
+�42�437��>+�8� >+�B0� �� �r