
    Oj?                       U d dl mZ dZd dlZd dlZd dlZd dlmZmZm	Z	m
Z
mZmZmZ d dlmZmZ d dlmZmZmZmZmZ ddlmZ dd	lmZ dd
lmZmZmZ ej>                  dk  rd dl m!Z!  ed      Z" ed      Z# e!d      Z$ ed       G d de	e"                Z%d:dZ& ed       G d dee"                Z' ed       G d dee"                Z( G d de	e"         Z)d;dZ*e*fdd	 	 	 	 	 	 	 d<dZ+dd	 	 	 	 	 	 	 d=dZ, G d  d!      Z- e-       Z.d!e/d"<   	 	 	 	 	 	 d>d#Z0	 	 	 	 	 	 d>d$Z1	 	 	 	 	 	 d?d%Z2d@dAd&Z3	 	 	 	 dBd'Z4	 	 	 	 	 	 dCd(Z5	 	 	 	 	 	 dCd)Z6e	 	 	 	 dDd*       Z7e	 	 	 	 	 	 dEd+       Z7	 dF	 	 	 	 	 dGd,Z7e	 	 	 	 	 	 dHd-       Z8e	 dI	 	 	 	 	 	 	 	 	 dJd.       Z8	 	 	 	 	 	 dKd/Z8	 	 	 	 dLd0Z9	 dF	 	 	 	 	 dMd1Z:dd2	 	 	 	 	 dNd3Z;dFdOd4Z<	 	 	 	 	 	 dPd5Z=	 dQ	 	 	 	 	 dRd6Z>	 	 	 	 	 	 dCd7Z?dd8	 	 	 	 	 dSd9Z@y)T    )annotations)Chain
accumulatebatchedcombinationscombinations_with_replacementcompresscountcycle	dropwhilefilterfalsegroupbyislicepairwisepermutationsproductrepeatstarmap	takewhiletee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)      )sentinelTR_tee_endF)eqc                       e Zd ZU ded<   ddZy)_IterableAsyncIteratorzIterator[T]iteratorc                   K   t                d {    	 t        | j                        }t	                d {    |S 7 .# t        $ r t	                d {  7   t
        d w xY w7 /wN)r+   nextr5   StopIterationr)   StopAsyncIteration)selfresults     f/var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/anyio/itertools.py	__anext__z _IterableAsyncIterator.__anext__9   sg     %'''	/$--(F
 )*** 	(  	/,...$$.	/ 	+s:   A*?A*A A*A(A*A%AA%%A*Nreturnr/   )__name__
__module____qualname____annotations__r>        r=   r4   r4   5   s    	rF   r4   c                    t        | t              r| S t        | t              r| j                         S t	        t        |             S r7   )
isinstancer   r   	__aiter__r4   iteriterables    r=   _iteraterM   E   s9    (M*(M*!!##!$x.11rF   c                  8    e Zd ZU dZded<   dZded<   dZded<   y)	_TeeLinkNzobject | Nonevaluez_TeeLink[T] | Noner8   Fboolfilled)rA   rB   rC   rP   rD   r8   rR   rE   rF   r=   rO   rO   O   s!    E=#D
#FDrF   rO   c                  <    e Zd ZU ded<    ee      Zded<   ddZy)		_TeeStateAsyncIterator[T]r5   )default_factoryr'   lockc                  K   |j                   ry| j                  4 d {    |j                   r	 d d d       d {    yt        | j                  t               d {   |_        |j
                  t        urt               |_        d|_         	 d d d       d {    y7 7 h7 G7 # 1 d {  7  sw Y   y xY wwNFT)rR   rW   anextr5   r1   rP   rO   r8   )r;   links     r=   fillz_TeeState.fill[   s     ;;99 		 		{{		 		 		  %T]]H==DJzz)$J	DK		 		 		 		 >			 		 		 		sq   CB$CB,CB&CB, B(!2B,CB*C&C(B,*C,B>2B53B>:CN)r[   _TeeLink[T]r@   rQ   )rA   rB   rC   rD   r    r'   rW   r\   rE   rF   r=   rT   rT   V   s    t,D$,rF   rT   c                  D    e Zd ZU ded<   ded<   ded<   	 	 	 	 d
dZddZy	)_TeeAsyncIteratorz_TeeState[T]_stater]   _linkrQ   _element_yieldedc                    t        |t              r*|j                  | _        |j                  | _        d| _        y t	        t        |            | _        t               | _        d| _        y )NF)rH   r_   r`   ra   rT   rM   rO   rb   )r;   rL   s     r=   __init__z_TeeAsyncIterator.__init__p   sS     h 12"//DK!DJ
 !& $HX$67DK!DJ %rF   c                  K   | j                   j                  | j                         d {   }| j                  j                  t        u r$| j
                  st                d {    t        |st                d {    d| _        t        t        | j                  j                        }| j                  j                  }|J || _        |st                d {    |S 7 7 7 j7 w)NT)r`   r\   ra   rP   r1   rb   r*   r:   r+   r$   r/   r8   r)   )r;   had_yieldpointrP   	next_links       r=   r>   z_TeeAsyncIterator.__anext__|   s     #{{//

;;::x'(( l""$$)+++ $Q

(()JJOO	$$$
,...% < #
 , /sF   )C.C&9C.%C(&C.?C* AC.C, C.(C.*C.,C.N)rL   z5Iterable[T] | AsyncIterable[T] | _TeeAsyncIterator[T]r@   Noner?   )rA   rB   rC   rD   rd   r>   rE   rF   r=   r_   r_   k   s.    
&M
&	
&rF   r_   c                6   K   t        j                  | |      S wr7   )operatoradd)xys     r=   _operator_addrn      s     <<1s   )initialc              D  K   t        |       }|	 t        |       d {   }n&t	                d {    |}t                d {    | |2 3 d {   } |||       d {   }|  7 R# t        $ r t                d {  7   Y y w xY w7 c7 Q7 C7 46 y wr7   )rM   rZ   r:   r*   r+   r)   )rL   functionro   r5   totalelements         r=   r   r      s      !H	/)E
 &'''(***
K!  gug.. *! 	,	 	(*. "s   B A4 A2A4 B BB BB BBBB 'B(
B 2A4 4B
BBB BB B BB B )strictc              V  K   |dk  rt        d      t        |       }	 g }t        |      D ]%  }	 |j                  t	        |       d {          ' t        |       D7 # t
        $ r8 |st                d {  7   Y  y |rt        d      d t        |       Y  y w xY ww)Nr&   zn must be at least onezbatched(): incomplete batch)
ValueErrorrM   rangeappendrZ   r:   r*   tuple)rL   nrt   r5   batch_s         r=   r   r      s      	1u122!H
q 	A
5?23	 El  3% $,&&$%BCMEl"sR   -B)A%	A#

A%B)#A%%B&=B >B&B)B&"B)%B&&B)c                  ,    e Zd Z	 	 	 	 ddZ	 	 	 	 ddZy)r   c                $    | j                  |      S r7   )from_iterable)r;   	iterabless     r=   __call__zChain.__call__   s     !!),,rF   c                 K   d}t        |      }	 |2 3 d {   }t        |      2 3 d {   }d}| 7  7 6 +6 	 t        |dd       }|xt        d      5   |        d {  7   d d d        nR# 1 sw Y   nIxY w# t        |dd       }|2t        d      5   |        d {  7   d d d        w # 1 sw Y   w xY ww xY w|st                d {  7   y y w)NFTaclose)shield)rM   getattrr(   r*   )r;   r   element_yielded
outer_iterrL   rs   r   s          r=   r   zChain.from_iterable   s       i(
		#", " "h%-h%7 " "'&*O!M""%7 #-
 Z48F! - # (NN# # # Z48F! - # (NN# # # " , s   CB >8>B <:<	B ><B  CA5&A)'A5,	C5A>:CCB7(B+
)B7.	C7C <CCCCN)r   Iterable[T] | AsyncIterable[T]r@   AsyncGenerator[T, None])r   zXIterable[Iterable[T] | AsyncIterable[T]] | AsyncIterable[Iterable[T] | AsyncIterable[T]]r@   r   )rA   rB   rC   r   r   rE   rF   r=   r   r      s0    -8-	 -
< 
!rF   r   chainc                  K   t        |       2 cg c3 d {   }|7 6 nc c}w }}t        t        j                  ||            2 3 d {  7  }| 6 y wr7   )rM   	itertoolsr   rL   rrs   poolcombinations        r=   r   r      sW      3;82DEEwWEEEDE%i&<&<T1&EF  k G>   A" 
 " "'AAAA	Ac                  K   t        |       2 cg c3 d {   }|7 6 nc c}w }}t        t        j                  ||            2 3 d {  7  }| 6 y wr7   )rM   r   r   r   s        r=   r   r      sX      3;82DEEwWEEEDE%i&M&MdTU&VW  k Xr   c                  K   t        |       }t        |      }d}	 	 t        |       d {   }t        |       d {   }|rd}| 17 !7 # t        $ r |st                d {  7   Y y w xY wwrY   rM   rZ   r:   r*   )data	selectorsdata_iteratorselector_iteratorr   datumselectors          r=   r	   r	      s~      TNM +O
	..E"#455H "OK .5! 	" l""		sT   A5A AA AA 
A5A A A2)A,*A2/A51A22A5c               z   K   | }	 t                d {    |}||z  }t                d {    | 17 #7 wr7   )r+   r)   )startsteprz   rP   s       r=   r
   r
     sG     A
%'''	T	(*** ' 	+s   ;7;9;;c                  K   g }t        |       2 3 d {   }|j                  |       |  7 6 |st                d {  7   y 	 |D ]  }t                d {  7   |   wr7   )rM   rx   r*   )rL   savedrs   s      r=   r   r     su      E!(+  gW+ l
 	G,M	 s7   A*202A*2A*AA*AA*c                  K   d}d}t        |      2 3 d {   }|r | |       d {   rd}d}| &7 !7 6 |st                d {  7   y y wrY   rM   r*   )	predicaterL   r   droppingrs   s        r=   r   r   .  sl      OH!(+  gi0000 , l s9   A<8<A:A<AAAAc                  K   d}t        |      2 3 d {   } | |       d {   rd}| "7 7 6 |st                d {  7   y y wrY   r   r   rL   r   rs   s       r=   r   r   A  s]      O!(+  gw'''"OM' ,
 l s>   A626A4AA6AAA	Ac                     y r7   rE   rK   s    r=   r   r   P  s     /2rF   c                     y r7   rE   )rL   keys     r=   r   r   V  s     /2rF   c               f  K   t        |       }	 t        |       d {   }||n ||       d {   }|g}|2 3 d {   }||n ||       d {   }||k7  r||f}|}|g}| 1|j	                  |       C7 `# t        $ r t                d {  7   Y y w xY w7 p7 d7 R6 ||f y wr7   )rM   rZ   r:   r*   rx   )rL   r   r5   rs   	group_keyvaluesnext_keycompleted_groups           r=   r   r   ]  s      !Hh'
 ;#g,,>IYF! # #g!k7S\/Ay '/O IYF!!MM'"! ( 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(	B1c                    y r7   rE   )rL   stops     r=   r   r   x  s    
 "rF   c                    y r7   rE   )rL   r   r   r   s       r=   r   r     s     "rF   c                 K   |st        d      t        |      dkD  rt        dt        |      dz          t        | }d}d}d}dd}|j                  d	n ||j                  |      }|j                  d n ||j                  |      }|j
                  dn ||j
                  |      }	|	d	k  rt        |      |d	k(  s||k(  rt                d {    y t        |       }
d	}d
}|||k  r?	 t        |
       d {   }||k\  r||z
  |	z  d	k(  r|dz  }d}| n|dz  }|9||k  r?|st                d {    y y 7 p7 G# t        $ r |st                d {  7   Y y w xY w7 .w)Nz+islice expected at least 2 arguments, got 1r,   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                    	 t        j                  t        t        |             }|dk  s|t        j                  kD  rt        |      |S # t        $ r t        |      d w xY w)Nr   )rj   indexr$   r!   	TypeErrorrv   sysmaxsize)rP   messager   s      r=   normalize_indexzislice.<locals>.normalize_index  s^    	0NN4U#34E 19+W%%  	0W%4/	0s   #A
 
A r   FT)rP   objectr   strr@   int)r   lenslicer   r   r   rv   r*   rM   rZ   r:   )rL   args
slice_argsstart_messagestop_messagestep_messager   r   r   r   r5   r   r   rs   s                 r=   r   r     s     EFF
4y1}CCIPQM?STTJ 	R  	X  KL	 # 	
Z--}= 
 ??" 	Z__l; 	 __$/*//<*X 	 qy&&qyETMl!HEO
,%$,	!(O+G E>uu}49QJE"OMQJE ,%$,  l / 	 ,! 	" l""		 	sl   CE/EE/1E	 ?E E	 $E/)E//E/>E-?E/E	 	E*!E$"E*'E/)E**E/c                  K   t        |       }	 t        |       d {   }d}|2 3 d {   }d}||f}|}| 7 # t        $ r t                d {  7   Y y w xY w7 66 |st                d {  7   y y wrY   r   )rL   r5   previousr   rs   pairs         r=   r   r     s      !Hx(
 O!  g'"
 ) l
 l si   A;? =? A;A#A!A#A;? AAAA;AA;!A##A;3A64A;c               .  K   t        |       2 cg c3 d {   }|7 6 nc c}w }}t        |      }||}n+t        |t              st	        d      |dk  rt        d      t        t        j                  ||            2 3 d {  7  }| 6 y w)NzExpected int as rr   zr must be non-negative)rM   r   rH   r   r   rv   r   r   )rL   r   rs   r   rz   permutations         r=   r   r     s      3;82DEEwWEEEDED	Ay3+,,	
Q122%i&<&<T1&EF  k Gs?   B" 
 " "A"BBB
B	B)r   c               H  K   t        j                  |       } | dk  rt        d      g }|D ]  }t        |      2 cg c3 d {   }| t        t        j                  |d| i      2 3 d {   }| 7 56 nc c}w }}|j	                  t        |             r7 06 y w)Nr   z"repeat argument cannot be negativer   )rj   r   rv   rM   rx   ry   r   r   )r   r   poolsrL   rs   r   rP   s          r=   r   r     s      ^^F#Fz=>>!#E "6>x6HII7"  	 1 15 H HI  e	 JIIIU4[!Is]   :B"A<A:A8A:A<
B")B -B.B 1B"8A::A<;#B"B  B"c               <  K   |	 t                d {    |  t        j                  t        t        |            }|dk  rt                d {    y |dkD  r5t                d {    |dz  }t                d {    |  |dkD  r4y y 7 7 B7 ,7 w)Nr   r&   )r*   rj   r   r$   r!   r+   r)   )rs   times	remainings      r=   r   r   
  s     },M  tC/0IA~l
a-%'''Q	(***	 a- 
 	 	(*sK   BB?BBB+B,BBBBBBBc                  K   d}t        |      2 3 d {   }t        |      2 cg c3 d {   }|7 7 	6 nc c}w }}d} | |  d {  7   E6 |st                d {  7   y y wrY   r   )rq   rL   result_yieldedargs_iterablers   r   s         r=   r   r     sx      N'1 $ $m-5m-DEE'$EEEEdO###  2
 l sV   A-A4AA-:868:A8:A-AA-%A(&A-c                    t        j                  t        t        |            }|dk  rt	        d      |dk(  ryt        |       g}|j                  fdt        |dz
        D               t        |      S )Nr   zn must be >= 0rE   c              3  4   K   | ]  }t                y wr7   )r_   ).0r|   r5   s     r=   	<genexpr>ztee.<locals>.<genexpr>9  s     GQ&x0Gs   r&   )	rj   r   r$   r!   rv   r_   extendrw   ry   )rL   rz   	iteratorsr5   s      @r=   r   r   .  sn     	tC|$A1u)**Av *H)1
IG%A,GGrF   c                  K   d}t        |      2 3 d {   } | |       d {   s|st                d {     y d}| 77 27 $7 6 |st                d {  7   y y wrY   r   r   s       r=   r   r   =  sr      O!(+  gw'''" l""'" , l sQ   A%AAAA%A	A%AA%A	A%A%A%A A%)	fillvaluec                 K   |D cg c]  }t        |       }}t        |      }|st                d {    y dg|z  }d}	 g }t        |      D ]A  \  }}	||   s|j	                  |        	 t        |	       d {   }
|j	                  |
       C d}t        |       bc c}w 7 u7 /# t        $ r) d||<   |dz  }|s|st                d {  7   Y  y | }
Y ^w xY ww)NTFr&   )rM   r   r*   	enumeraterx   rZ   r:   ry   )r   r   rL   r   
num_activeactivetuple_yieldedr   r   r5   rP   s              r=   r   r   Q  s      5>>(#>I>YJlVj FM
!(3 	!OE8%=i("#Ho- MM% %	!( Fm/  ? 	 .% 	" %ua
!((l**!	"sg   C$B&C$B+8C$/B/=B->B/*C$-B//$C!CC!C$C!C$ C!!C$)rL   r   r@   rU   )rl   r/   rm   r/   r@   r/   )rL   r   rq   zCallable[[T, T], Awaitable[T]]ro   zT | Noner@   r   )rL   r   rz   r   rt   rQ   r@   #AsyncGenerator[tuple[T, ...], None])rL   r   r   r   r@   r   )r   r   r   (Iterable[object] | AsyncIterable[object]r@   r   )r   r&   )r   r   r   r   r@   zAsyncGenerator[int, None])rL   r   r@   r   )r   z Callable[[T], Awaitable[object]]rL   r   r@   r   )rL   r   r@   z'AsyncGenerator[tuple[T, list[T]], None])rL   r   r   zCallable[[T], Awaitable[R]]r@   z'AsyncGenerator[tuple[R, list[T]], None]r7   )rL   r   r   z'Callable[[T], Awaitable[object]] | Noner@   z,AsyncGenerator[tuple[object, list[T]], None])rL   r   r   
int | Noner@   r   )r&   )
rL   r   r   r   r   r   r   r   r@   r   )rL   r   r   r   r@   r   )rL   r   r@   z!AsyncGenerator[tuple[T, T], None])rL   r   r   r   r@   r   )r   r   r   r   r@   r   )rs   r/   r   r   r@   r   )rq   zCallable[..., Awaitable[R]]rL   zlIterable[Iterable[object] | AsyncIterable[object]] | AsyncIterable[Iterable[object] | AsyncIterable[object]]r@   zAsyncGenerator[R, None])   )rL   r   rz   r   r@   ztuple[AsyncIterator[T], ...])r   r   r   r   r@   z(AsyncGenerator[tuple[object, ...], None])A
__future__r   __all__r   rj   r   collections.abcr   r   r   r   r   r   r   dataclassesr   r    typingr!   r"   r#   r$   r%   _core._synchronizationr'   _core._tasksr(   lowlevelr)   r*   r+   version_infotyping_extensionsr.   r/   r0   r1   r4   rM   rO   rT   r_   rn   r   r   r   r   rD   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   rE   rF   r=   <module>r      s   ".   
   ) 8 8 ( % U Ug*CLCLJ e]1-  2 ewqz   e
  ($a( $N 0= 	,, 	
 4 IN,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$$ .$rF   