← back to Atmos Game

assets/gen/.venv/lib/python3.12/site-packages/anyio/__pycache__/itertools.cpython-312.pyc

102 lines

�

c�bj(?����UddlmZdZddlZddlZddlZddlmZmZm	Z	m
Z
mZmZm
Z
ddlmZmZddlmZmZmZmZmZddlmZdd	lmZdd
lmZmZmZed�Zed�Z e!�Z"ed
��Gd�de	e��Z#d7d�Z$ed
��Gd�dee��Z%ed
��Gd�dee��Z&Gd�de	e�Z'd8d�Z(e(fdd�							d9d�Z)d
d�							d:d�Z*Gd�d�Z+e+�Z,de-d<						d;d �Z.						d;d!�Z/						d<d"�Z0d=d>d#�Z1				d?d$�Z2						d@d%�Z3						d@d&�Z4e				dAd'��Z5e						dBd(��Z5	dC					dDd)�Z5e						dEd*��Z6e	dF									dGd+��Z6						dHd,�Z6				dId-�Z7	dC					dJd.�Z8dd/�					dKd0�Z9dCdLd1�Z:						dMd2�Z;	dN					dOd3�Z<						d@d4�Z=dd5�					dPd6�Z>y)Q�)�annotations)�
accumulate�batched�Chain�combinations�combinations_with_replacement�compress�count�cycle�	dropwhile�filterfalse�groupby�islice�pairwise�permutations�product�repeat�starmap�tee�	takewhile�zip_longestN)�AsyncGenerator�
AsyncIterable�
AsyncIterator�	Awaitable�Callable�Iterable�Iterator)�	dataclass�field)�Any�Generic�TypeVar�cast�overload�)�Lock)�CancelScope)�cancel_shielded_checkpoint�
checkpoint�checkpoint_if_cancelled�T�RF)�eqc� �eZdZUded<dd�Zy)�_IterableAsyncIteratorzIterator[T]�iteratorc���K�t��d{���	t|j�}t	��d{���|S7�.#t$rt	��d{���7t
d�wxYw7�/�w�N)r+�nextr1�
StopIterationr)�StopAsyncIteration)�self�results  �f/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/anyio/itertools.py�	__anext__z _IterableAsyncIterator.__anext__6sg����%�'�'�'�	/��$�-�-�(�F�
)�*�*�*��
�	(���	/�,�.�.�.�$�$�.�	/��	+�s:�A*�?�A*�A�
A*�A(�A*�A%�A�
A%�%A*N��returnr,)�__name__�
__module__�__qualname__�__annotations__r:��r9r0r02s
����	rBr0c��t|t�r|St|t�r|j�St	t|��Sr3)�
isinstancerr�	__aiter__r0�iter��iterables r9�_iteraterIBs9���(�M�*����(�M�*��!�!�#�#�!�$�x�.�1�1rBc�8�eZdZUdZded<dZded<dZded<y)	�_TeeLinkNz
object | None�valuez_TeeLink[T] | Noner4F�bool�filled)r=r>r?rLr@r4rNrArBr9rKrKLs!���E�=��#�D�
�#��F�D�rBrKc�<�eZdZUded<ee��Zded<dd�Zy)	�	_TeeState�AsyncIterator[T]r1)�default_factoryr'�lockc��K�|jry|j4�d{���|jr	ddd��d{���yt|jt��d{���|_|j
turt
�|_d|_	ddd��d{���y7��7�h7�G7�#1�d{���7swYyxYw�w�NFT)rNrS�anextr1�_tee_endrLrKr4)r7�links  r9�fillz_TeeState.fillXs������;�;���9�9�9��{�{���9�9� %�T�]�]�H�=�=�D�J��z�z��)�$�J��	��D�K���9�9��9��>��	��9�9�9�sq�C�B$�C�B,�C�B&�C�B,� B(�!2B,�C�B*�C�&C�(B,�*C�,B>�2B5�3B>�:CN)rX�_TeeLink[T]r<rM)r=r>r?r@r r'rSrYrArBr9rPrPSs�����t�,�D�$�,�
rBrPc�D�eZdZUded<ded<ded<				d
d�Zdd�Zy	)�_TeeAsyncIteratorz_TeeState[T]�_staterZ�_linkrM�_element_yieldedc���t|t�r*|j|_|j|_d|_yt	t|��|_t
�|_d|_y)NF)rDr\r]r^rPrIrKr_)r7rHs  r9�__init__z_TeeAsyncIterator.__init__msS���h� 1�2�"�/�/�D�K�!���D�J�
!&���$�H�X�$6�7�D�K�!��D�J� %��rBc���K�|jj|j��d{���}|jjtur$|j
st
��d{���t�|st��d{���d|_tt|jj�}|jj}|�J�||_|st��d{���|S7��7��7�j7��w)NT)
r]rYr^rLrWr_r*r6r+r$r,r4r))r7�had_yieldpointrL�	next_links    r9r:z_TeeAsyncIterator.__anext__ys�����#�{�{�/�/��
�
�;�;���:�:���x�'��(�(� �l�"�"�$�$��)�+�+�+� $����Q��
�
�(�(�)���J�J�O�O�	��$�$�$���
��,�.�.�.���%<��#��

,��
/�sF�)C.�C&�9C.�%C(�&C.�?C*�AC.�C,� C.�(C.�*C.�,C.N)rHz5Iterable[T] | AsyncIterable[T] | _TeeAsyncIterator[T]r<�Noner;)r=r>r?r@rar:rArBr9r\r\hs.��������
&�M�
&�	
�
&�rBr\c��6K�tj||�S�wr3)�operator�add)�x�ys  r9�
_operator_addrk�s�����<�<��1���s�)�initialc�DK�t|�}|�	t|��d{���}n&t	��d{���|}t��d{���|���|23d{���}|||��d{���}|���� 7�R#t$rt��d{���7YywxYw7�c7�Q7�C7�46y�wr3)rIrVr6r*r+r))rH�functionrlr1�total�elements      r9rr�s�������!�H���	���/�)�E�
&�'�'�'���(�*�*�*�
�K�!��g��u�g�.�.����*��!�	��,����	��	(��*����.��"�s��B �A4�A2�A4�B �B�B �B�B �B�B�B�
B �'B�(
B �2A4�4B�
B
�B�B �B�B �B �B�B �B )�strictc�VK�|dkrtd��t|�}	g}t|�D]%}	|jt	|��d{�����'t|�����D7�#t
$r8|st
��d{���7Yy|rtd�d�t|����YywxYw�w)Nr&zn must be at least onezbatched(): incomplete batch)�
ValueErrorrI�range�appendrVr6r*�tuple)rH�nrqr1�batch�_s      r9rr�s�����	�1�u��1�2�2���!�H�
����q��A�

����5��?�2�3���E�l���3��%�
��$�,�&�&���$�%B�C��M��E�l�"��
�sR�-B)�A%�	A#
�
A%�B)�#A%�%B&�=B�>B&�B)�B&�"B)�%B&�&B)c�,�eZdZ				dd�Z				dd�Zy)rc�$�|j|�Sr3)�
from_iterable)r7�	iterabless  r9�__call__zChain.__call__�s���!�!�)�,�,rBc��K�d}t|�}	|23d{���}t|�23d{���}d}|����7� 7�6�+6	t|dd�}|�xtd��5|��d{���7ddd�nR#1swYnIxYw#t|dd�}|�2td��5|��d{���7ddd�w#1swYwxYwwxYw|st��d{���7yy�w)NFT�aclose)�shield)rI�getattrr(r*)r7r}�element_yielded�
outer_iterrHrpr�s       r9r|zChain.from_iterable�s����� ���i�(�
�		#�",�
"�h�%-�h�%7�"�'�&*�O�!�M�
"��"��%7�#-�
�Z��4�8�F��!� ��-� �(�N�N�.�-�-���Z��4�8�F��!� ��-� �(�N�N�.�-�-��"����,����s��C�B�>�8�>�B�<�:�<�	B�>�<�B�C�A5�&A)�'A5�,	C�5A>�:C�C�B7�(B+
�)B7�.	C�7C�<C�C�C�CN)r}�Iterable[T] | AsyncIterable[T]r<�AsyncGenerator[T, None])r}zXIterable[Iterable[T] | AsyncIterable[T]] | AsyncIterable[Iterable[T] | AsyncIterable[T]]r<r�)r=r>r?r~r|rArBr9rr�s0��-�8�-�	 �-�
�
<��
!�
rBr�chainc�K�t|�2�cgc3d{���}|��7�6ncc}w}}ttj||��23d{���7}|����6y�wr3)rI�	itertoolsr�rH�rrp�pool�combinations     r9rr�sW����3;�8�2D�E�E�w�W�E��E��E�D�E�%�i�&<�&<�T�1�&E�F���k���G��>�A�"� �
� �"� �"�'A�A�A�
A�	Ac�K�t|�2�cgc3d{���}|��7�6ncc}w}}ttj||��23d{���7}|����6y�wr3)rIr�rr�s     r9rr�sX����3;�8�2D�E�E�w�W�E��E��E�D�E�%�i�&M�&M�d�TU�&V�W���k���X�r�c��K�t|�}t|�}d}		t|��d{���}t|��d{���}|rd}|����17�!7�#t$r|st��d{���7YywxYw�wrU�rIrVr6r*)�data�	selectors�
data_iterator�selector_iteratorr��datum�selectors       r9r	r	�s~�����T�N�M� ��+���O�
�	��
�.�.�E�"�#4�5�5�H��"�O��K��.��5��!�	�"� �l�"�"��		�sT�A5�A�A
�A�A�A�
A5�
A�A�A2�)A,�*A2�/A5�1A2�2A5c�zK�|}	t��d{���|}||z
}t��d{���|����17�#7��wr3)r+r))�start�steprwrLs    r9r
r
sG����
�A�
�%�'�'�'���	�T�	��(�*�*�*����'��	+�s�;�7�;�9�;�;c��K�g}t|�23d{���}|j|�|���� 7�6|st��d{���7y	|D]}t��d{���7|����� �wr3)rIrur*)rH�savedrps   r9rrsk�����E�!�(�+��g�
���W���
���+���l����
��G��,����M���s7�A*�2�0�2�A*�2�A*�A�A*�A�
A*c�K�d}d}t|�23d{���}|r||��d{���r�d}d}|����&7�!7�6|st��d{���7yy�wrU�rIr*)�	predicaterHr��droppingrps     r9rr+sg�����O��H�!�(�+��g��i��0�0�0�������
�
��0��,���l����s9�A�<�8�<�A�:�A�<�A�A�A�
Ac�K�d}t|�23d{���}||��d{���r�d}|����"7�7�6|st��d{���7yy�wrUr��r�rHr�rps    r9r
r
>sX�����O�!�(�+��g��w�'�'�'�"�O��M���'��,�
��l����s>�A�6�2�6�A�4�A�A�6�A�A�A	�Ac��yr3rArGs r9rrMs��/2rBc��yr3rA)rH�keys  r9rrSs��/2rBc�fK�t|�}	t|��d{���}|�|n||��d{���}|g}|23d{���}|�|n||��d{���}||k7r||f}|}|g}|����1|j	|��C7�`#t$rt��d{���7YywxYw7�p7�d7�R6||f���y�wr3)rIrVr6r*ru)rHr�r1rp�	group_key�values�next_key�completed_groups        r9rrZs�������!�H���h��'��
�;��#�g�,�,>�I��Y�F�!�#�g�!�k�7�S��\�/A���y� �'��/�O� �I��Y�F�!�!��M�M�'�"�!(�����l������-?��#��/A��"��V�
��s��B1�B�A>�B�B1�B"�	B1�B(�B$�B(�B1�B&�*B1�>B�B�B�B�B1�B�B1�$B(�&B1�(	B1c��yr3rA)rH�stops  r9rrus��
"rBc��yr3rA)rHr�r�r�s    r9rr}s��"rBc��K�|std��t|�dkDrtdt|�dz����t|�}d}d}d}dd�}|j�d	n||j|�}|j�dn||j|�}|j
�dn||j
|�}	|	d	krt
|��|d	k(s||k(rt��d{���yt|�}
d	}d
}|�||kr?	t|
��d{���}
||k\r||z
|	zd	k(r
|dz
}d}|
���n|dz
}|��9||kr�?|st��d{���yy7�p7�G#t$r|st��d{���7YywxYw7�.�w)
Nz+islice expected at least 2 arguments, got 1�z)islice expected at most 4 arguments, got r&zGIndices for islice() must be None or an integer: 0 <= x <= sys.maxsize.zMStop argument for islice() must be None or an integer: 0 <= x <= sys.maxsize.z5Step for islice() must be a positive integer or None.c���	tjtt|��}|dks|tjkDrt|��|S#t$r
t|�d�wxYw)Nr)rg�indexr$r!�	TypeErrorrs�sys�maxsize)rL�messager�s   r9�normalize_indexzislice.<locals>.normalize_index�s^��	0��N�N�4��U�#3�4�E��1�9�����+��W�%�%����
�	0��W�%�4�/�	0�s�#A
�
A rFT)rL�objectr��strr<�int)r��len�slicer�r�r�rsr*rIrVr6)rH�args�
slice_args�
start_message�stop_message�step_messager�r�r�r�r1r�r�rps              r9rr�s�������E�F�F�
�4�y�1�}��C�C��I�PQ�M�?�S�T�T����J�	R��	X��K�L�	����#�	
�
�Z�-�-�}�
=�
��?�?�"�	
�
�Z�_�_�l�
;�	��_�_�
$��/�*�/�/�<�*X�	��q�y���&�&��q�y�E�T�M��l������!�H�
�E��O�
�,�%�$�,�	�!�(�O�+�G��E�>�u�u�}��4��9��Q�J�E�"�O��M��Q�J�E��,�%�$�,� ��l����/	��,��!�	�"� �l�"�"��		��	�sl�CE/�E�E/�1E	�?E�E	�$E/�)E/�/E/�>E-�?E/�E	�	E*�!E$�"E*�'E/�)E*�*E/c��K�t|�}	t|��d{���}d}|23d{���}d}||f}|}|����7�#t$rt��d{���7YywxYw7�66|st��d{���7yy�wrUr�)rHr1�previousr�rp�pairs      r9rr�s�������!�H���x��(��
�O�!��g����'�"�����
�)�����l������
�����l����si�A;�?�=�?�A;�A#�A!�A#�A;�?�A�A�A�A;�A�A;�!A#�#A;�3A6�4A;c�.K�t|�2�cgc3d{���}|��7�6ncc}w}}t|�}|�|}n+t|t�st	d��|dkrtd��tt
j||��23d{���7}|����6y�w)NzExpected int as rrzr must be non-negative)rIr�rDr�r�rsr�r)rHr�rpr�rw�permutations      r9rr�s�����3;�8�2D�E�E�w�W�E��E��E�D�E��D�	�A��y�
��
��3�
��+�,�,�	
�Q���1�2�2�%�i�&<�&<�T�1�&E�F���k���G�s?�B�"� �
� �"� �"�A"B�B�B
�B�	B)rc�HK�tj|�}|dkrtd��g}|D]}t|�2�cgc3d{���}|��tt
j|d|i��23d{���}|����7�56ncc}w}}|j	t|���r7�06y�w)Nrz"repeat argument cannot be negativer)rgr�rsrIrurvr�r)rr}�poolsrHrpr�rLs       r9rr�s������^�^�F�
#�F�
��z��=�>�>�!#�E���6>�x�6H�I�I�7��� �	� 1� 1�5� H�� H�I��e���	J��I��I��I�
���U�4�[�!���I�s]�:B"�A<�A:�A8�A:�A<�
B"�)B �-B�.B �1B"�8A:�:A<�;#B"�B � B"c�<K�|�	t��d{���|����tjtt|��}|dkrt��d{���y|dkDr5t��d{���|dz}t
��d{���|���|dkDr�4yy7��7�B7�,7��w)Nrr&)r*rgr�r$r!r+r))rp�times�	remainings   r9rrs������}���,����M�����t�C��/�0�I��A�~��l����
�a�-�%�'�'�'��Q��	�(�*�*�*��
�	�a�-�
��
	��	(��*�sK�B�B�?B�B�B�+B�,B�B�B�B�B�B�Bc��K�d}t|�23d{���}t|�2�cgc3d{���}|��7�7�	6ncc}w}}d}||��d{���7����E6|st��d{���7yy�wrUr�)rnrH�result_yielded�
args_iterablerpr�s      r9rrss�����N�'��1�$�m�-5�m�-D�E�E�'��$��E��E��E��E����d�O�#�#�#� 2�
��l����sV�A-�A�4�A�A-�:�8�6�8�:�A�8�:�A-�A�A-�%A(�&A-c����tjtt|��}|dkrt	d��|dk(ryt|���g}|j
�fd�t|dz
�D��t|�S)Nrzn must be >= 0rAc3�4�K�|]}t�����y�wr3)r\)�.0ryr1s  �r9�	<genexpr>ztee.<locals>.<genexpr>6s�����G�,�Q�&�x�0�,�s�r&)	rgr�r$r!rsr\�extendrtrv)rHrw�	iteratorsr1s   @r9rr+sn���	���t�C��|�$�A��1�u��)�*�*��A�v�� ��*�H�)1�
�I�
���G�%��A��,�G�G����rBc��K�d}t|�23d{���}||��d{���s|st��d{���yd}|����77�27�$7�6|st��d{���7yy�wrUr�r�s    r9rr:sm�����O�!�(�+��g��w�'�'�'�"� �l�"�"�����
���'��"��,���l����sQ�A%�A
�A�A
�A%�A	�A%�A�A%�A
�	A%�A%�
A%�A �A%)�	fillvaluec��K�|D�cgc]
}t|���}}t|�}|st��d{���ydg|z}d}	g}t|�D]A\}}	||s|j	|��	t|	��d{���}
|j	|
��Cd}t|�����bcc}w7�u7�/#t$r)d||<|dz}|s|st��d{���7Yy|}
Y�^wxYw�w)NTFr&)rIr�r*�	enumeraterurVr6rv)r�r}rHr��
num_active�active�
tuple_yieldedr�r�r1rLs           r9rrNs�����5>�>�I���(�#�I�I�>��Y��J���l�����V�j�
 �F��M�
�!��(��3�O�E�8��%�=��
�
�i�(��
"�#�H�o�-��
�M�M�%� �% 4�(�
��F�m��/��?�	��.��%�	
"� %��u�
��a��
�!�(�(�l�*�*��!��	
"�sg�C$�B&�C$�B+�8C$�/B/�=B-�>B/�*C$�-B/�/$C!�C�C!�C$�C!�C$� C!�!C$)rHr�r<rQ)rir,rjr,r<r,)rHr�rnzCallable[[T, T], Awaitable[T]]rlzT | Noner<r�)rHr�rwr�rqrMr<�#AsyncGenerator[tuple[T, ...], None])rHr�r�r�r<r�)r�r�r��(Iterable[object] | AsyncIterable[object]r<r�)rr&)r�r�r�r�r<zAsyncGenerator[int, None])rHr�r<r�)r�z Callable[[T], Awaitable[object]]rHr�r<r�)rHr�r<z'AsyncGenerator[tuple[T, list[T]], None])rHr�r�zCallable[[T], Awaitable[R]]r<z'AsyncGenerator[tuple[R, list[T]], None]r3)rHr�r�z'Callable[[T], Awaitable[object]] | Noner<z,AsyncGenerator[tuple[object, list[T]], None])rHr�r��
int | Noner<r�)r&)
rHr�r�r�r�r�r�r�r<r�)rHr�r�r�r<r�)rHr�r<z!AsyncGenerator[tuple[T, T], None])rHr�r�r�r<r�)r}r�rr�r<r�)rpr,r�r�r<r�)rnzCallable[..., Awaitable[R]]rHzlIterable[Iterable[object] | AsyncIterable[object]] | AsyncIterable[Iterable[object] | AsyncIterable[object]]r<zAsyncGenerator[R, None])�)rHr�rwr�r<ztuple[AsyncIterator[T], ...])r}r�r�r�r<z(AsyncGenerator[tuple[object, ...], None])?�
__future__r�__all__r�rgr��collections.abcrrrrrrr�dataclassesrr �typingr!r"r#r$r%�_core._synchronizationr'�_core._tasksr(�lowlevelr)r*r+r,r-r�rWr0rIrKrPr\rkrrrr�r@rrr	r
rrr
rrrrrrrrrrrArBr9�<module>r�s��"���.��
����)�8�8�(�%�U�U��C�L���C�L���8���e���]�1�-����2��e���w�q�z�����e�����
����($�
�a�(�$�N�0=���	�,��,���	�
��4IN��,��14��AE��(��4��>�w��u���,��14��(���,��14��(���
(��7����.��,����$�/��,����&�/��,����
�2�,�2�,�2�
�2�

�2�,�2�	$�2�-�2�
�2�48��,��	0��2��6
�"�,�"�
�"��	"�
�"�
�
�	"�,�"��"��"��	"��
"�
�"�H�,�H��H��H�V�,��&��,?C�
�,�
�1;�
�(�
�"?@�
�.�
�8;�
�(�
� �$�)��	B���
�&89��,��14��!���/��,����,�$�8�$��$�.�$rB