
    zbj?                    0   % S SK Jr  SrS SKrS SKrS SKrS SKJrJrJ	r	J
r
JrJrJr  S SKJrJr  S SKJrJrJrJrJr  SSKJr  SS	KJr  SS
KJrJrJr  \R>                  S:  a  S SK J!r!  \" S5      r"\" S5      r#\!" S5      r$\" SS9 " S S\	\"   5      5       r%S:S jr&\" SS9 " S S\\"   5      5       r'\" SS9 " S S\\"   5      5       r( " S S\	\"   5      r)S;S jr*\*4SS.       S<S jjjr+SS.       S=S jjr, " S  S!5      r-\-" 5       r.S!\/S"'         S>S# jr0      S>S$ jr1      S?S% jr2S@SAS& jjr3    SBS' jr4      SCS( jr5      SCS) jr6\    SDS* j5       r7\      SES+ j5       r7 SF     SGS, jjr7\      SHS- j5       r8\ SI         SJS. jj5       r8      SKS/ jr8    SLS0 jr9 SF     SMS1 jjr:SS2.     SNS3 jjr;SFSOS4 jjr<      SPS5 jr= SQ     SRS6 jjr>      SCS7 jr?SS8.     SSS9 jjr@g)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                  *    \ rS rSr% S\S'   SS jrSrg)_IterableAsyncIterator5   zIterator[T]iteratorc                   #    [        5       I S h  vN    [        U R                  5      n[	        5       I S h  vN   U$  N.! [         a    [	        5       I S h  vN    [
        S ef = f N07fN)r+   nextr6   StopIterationr)   StopAsyncIteration)selfresults     ڋ/tmp/claude-0/-home-danvics-docker-quiz/c1e0577a-e42c-4a3d-b1ea-3edd61103a4e/scratchpad/stt/lib/python3.13/site-packages/anyio/itertools.py	__anext__ _IterableAsyncIterator.__anext__9   sf     %'''	/$--(F
 )*** 	(  	/,...$$.	/ 	+s:   A+?A+A A+A)A+A&AA&&A+ Nreturnr/   )__name__
__module____qualname____firstlineno____annotations__r?   __static_attributes__rA       r>   r4   r4   5   s    	rJ   r4   c                    [        U [        5      (       a  U $ [        U [        5      (       a  U R                  5       $ [	        [        U 5      5      $ r8   )
isinstancer   r   	__aiter__r4   iteriterables    r>   _iteraterQ   E   s?    (M**(M**!!##!$x.11rJ   c                  @    \ rS rSr% SrS\S'   SrS\S'   SrS\S	'   S
rg)_TeeLinkO   Nzobject | Nonevaluez_TeeLink[T] | Noner9   FboolfilledrA   )	rD   rE   rF   rG   rU   rH   r9   rW   rI   rA   rJ   r>   rS   rS   O   s!    E=#D
#FDrJ   rS   c                  @    \ rS rSr% S\S'   \" \S9rS\S'   S
S jrSr	g	)	_TeeStateV   AsyncIterator[T]r6   )default_factoryr'   lockc                  #    UR                   (       a  gU R                   IS h  vN   UR                   (       a   S S S 5      IS h  vN   g[        U R                  [        5      I S h  vN Ul        UR
                  [        La  [        5       Ul        SUl          S S S 5      IS h  vN   g N Ni NH N! , IS h  vN  (       d  f       g = f7fNFT)rW   r]   anextr6   r1   rU   rS   r9   )r<   links     r>   fill_TeeState.fill[   sz     ;;999{{ 99  %T]]H==DJzz)$J	DK 99 >	 999ss   #CB/CB7CB1CB7*B3+3B7C)B5*C1C3B75C7C=C >C
CrA   N)ra   _TeeLink[T]rC   rV   )
rD   rE   rF   rG   rH   r    r'   r]   rb   rI   rA   rJ   r>   rY   rY   V   s    t,D$,rJ   rY   c                  P    \ rS rSr% S\S'   S\S'   S\S'       SS jrSS	 jrS
rg)_TeeAsyncIteratork   z_TeeState[T]_staterd   _linkrV   _element_yieldedc                    [        U[        5      (       a#  UR                  U l        UR                  U l        O([	        [        U5      5      U l        [        5       U l        SU l        g )NF)rL   rf   rh   ri   rY   rQ   rS   rj   )r<   rP   s     r>   __init___TeeAsyncIterator.__init__p   sJ     h 122"//DK!DJ#HX$67DK!DJ %rJ   c                   #    U R                   R                  U R                  5      I S h  vN nU R                  R                  [        L a)  U R
                  (       d  [        5       I S h  vN   [        eU(       d  [        5       I S h  vN   SU l        [        [        U R                  R                  5      nU R                  R                  nUc   eX0l        U(       d  [        5       I S h  vN   U$  N N No N7f)NT)rh   rb   ri   rU   r1   rj   r*   r;   r+   r$   r/   r9   r)   )r<   had_yieldpointrU   	next_links       r>   r?   _TeeAsyncIterator.__anext__|   s     #{{//

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

(()JJOO	$$$
,...% < #
 , /sF   )C>C6?C>+C8,C>
C:A$C>/C<0C>8C>:C><C>)rj   ri   rh   N)rP   z5Iterable[T] | AsyncIterable[T] | _TeeAsyncIterator[T]rC   NonerB   )rD   rE   rF   rG   rH   rl   r?   rI   rA   rJ   r>   rf   rf   k   s.    
&M
&	
&rJ   rf   c                6   #    [         R                  " X5      $ 7fr8   )operatoradd)xys     r>   _operator_addrx      s     <<s   )initialc              H  #    [        U 5      nUc   [        U5      I S h  vN nO&[	        5       I S h  vN   Un[        5       I S h  vN   U7v   U  S h  vN nU" XE5      I S h  vN nU7v   M    NR! [         a    [        5       I S h  vN     g f = f Nd NR ND N6
 g 7fr8   )rQ   r`   r;   r*   r+   r)   )rP   functionry   r6   totalelements         r>   r   r      s      !H	/)E
 &'''(***
K! gu.. *! 	,	 	(*. "s   B"A5 A3A5 B"BB"BB"B BB B"'B(B"3A5 5BBBB"BB"B"B B" B")strictc              t  #    US:  a  [        S5      e[        U 5      n / n[        U5       H&  n UR                  [	        U5      I S h  vN 5        M(     [        U5      7v   MG   N! [
         aB    U(       d  [        5       I S h  vN       g U(       a  [        S5      S e[        U5      7v      g f = f7f)Nr&   zn must be at least onezbatched(): incomplete batch)
ValueErrorrQ   rangeappendr`   r;   r*   tuple)rP   nr~   r6   batch_s         r>   r   r      s      	1u122!H
qA
5?23  El  3% $,&&$%BCMEl"sR   .B8A)
A'
A)B8'A))B5B
B5B8!B51B84B55B8c                  8    \ rS rSr    SS jr    SS jrSrg)r      c                $    U R                  U5      $ r8   )from_iterable)r<   	iterabless     r>   __call__Chain.__call__   s     !!),,rJ   c                 #    Sn[        U5      n U  S h  vN n[        U5        S h  vN nSnU7v   M   N! N
 M-  
 [        USS 5      nUb4  [        SS9   U" 5       I S h  vN    S S S 5        O[! , (       d  f       OM= fOI! [        USS 5      nUb4  [        SS9   U" 5       I S h  vN    S S S 5        f ! , (       d  f       f = ff = fU(       d  [        5       I S h  vN    g g 7f)NFTaclose)shield)rQ   getattrr(   r*   )r<   r   element_yielded
outer_iterrP   r}   r   s          r>   r   Chain.from_iterable   s       i(
		#", "h%-h%7 "'&*O!M""%7 #-
 Z48F! - (NN .-- " Z48F! - (NN .-- " , s   C+B A 9A B =;=
B A =B C+A4%A(&A4+	C+4
B>C+C B:+B.
,B:1	C:
CCC+#C&$C+rA   N)r   Iterable[T] | AsyncIterable[T]rC   AsyncGenerator[T, None])r   zXIterable[Iterable[T] | AsyncIterable[T]] | AsyncIterable[Iterable[T] | AsyncIterable[T]]rC   r   )rD   rE   rF   rG   r   r   rI   rA   rJ   r>   r   r      s0    -8-	 -
< 
!rJ   r   chainc                  #    [        U 5       Vs/ s S h  vN o"PM   N
 Os  snf nn[        [        R                  " X15      5        S h  vN  nU7v   M  
 g 7fr8   )rQ   	itertoolsr   rP   rr}   poolcombinations        r>   r   r      sP      3;82DEEwWEEDE%i&<&<T&EF  k G>   A" 
 " "'AAAA
Ac                  #    [        U 5       Vs/ s S h  vN o"PM   N
 Os  snf nn[        [        R                  " X15      5        S h  vN  nU7v   M  
 g 7fr8   )rQ   r   r   r   s        r>   r   r      sP      3;82DEEwWEEDE%i&M&Md&VW  k Xr   c                 #    [        U 5      n[        U5      nSn  [        U5      I S h  vN n[        U5      I S h  vN nU(       a  SnU7v   M7   N' N! [         a    U(       d  [        5       I S h  vN     g f = f7fr_   rQ   r`   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   BA AA AA BA A A>5A86A>;B=A>>Bc               z   #    U n [        5       I S h  vN   UnX!-  n[        5       I S h  vN   U7v   M1   N# N7fr8   )r+   r)   )startstepr   rU   s       r>   r
   r
     sC     A
%'''		(*** ' 	+s   ;7;9;;c                  #    / n[        U 5        S h  vN nUR                  U5        U7v   M!   N
 U(       d  [        5       I S h  vN    g  U H  n[        5       I S h  vN    U7v   M     M#  7fr8   )rQ   r   r*   )rP   savedr}   s      r>   r   r     si      E!(+ gW+ l
G,M  s7   A3313A33A3A	A3"A%#A3c                  #    SnSn[        U5        S h  vN nU(       a  U " U5      I S h  vN (       a  M'  SnSnU7v   M2   N- N
 U(       d  [        5       I S h  vN    g g 7fr_   rQ   r*   )	predicaterP   r   droppingr}   s        r>   r   r   .  sd      OH!(+ gi0000 , l sA   A%AAAA%AA%AA%A%A A%c                  #    Sn[        U5        S h  vN nU " U5      I S h  vN (       a  M   SnU7v   M)   N$ N
 U(       d  [        5       I S h  vN    g g 7fr_   r   r   rP   r   r}   s       r>   r   r   A  sU      O!(+ gw'''"OM' ,
 l s>   A=9=A;A	A=AAAAc                    g r8   rA   rO   s    r>   r   r   P  s     /2rJ   c                    g r8   rA   )rP   keys     r>   r   r   V  s     /2rJ   c               l  #    [        U 5      n [        U5      I S h  vN nUc  UOU" U5      I S h  vN nU/nU  S h  vN nUc  UOU" U5      I S h  vN nXd:w  a  XE4nUnU/nU7v   M2  UR	                  U5        ME   Nc! [         a    [        5       I S h  vN     g f = f Ns Ng NT
 XE47v   g 7fr8   )rQ   r`   r;   r*   r   )rP   r   r6   r}   	group_keyvaluesnext_keycompleted_groups           r>   r   r   ]  s      !Hh'
 ;#g,,>IYF! #g!k7S\/A '/O IYF!!MM'"! ( l -?#/A " 
s   B4B BB B4B&	B4B, B(B,B4B*+B4B B#BB# B4"B##B4(B,*B4,B4c                   g r8   rA   )rP   stops     r>   r   r   x  s    
 "rJ   c                   g r8   rA   )rP   r   r   r   s       r>   r   r     s     "rJ   c                 #    U(       d  [        S5      e[        U5      S:  a  [        S[        U5      S-    35      e[        U6 nSnSnSnSS jnUR                  c  S	OU" UR                  U5      nUR                  c  S OU" UR                  U5      nUR
                  c  SOU" UR
                  U5      n	U	S	::  a  [        U5      eUS	:X  d  Xx:X  a  [        5       I S h  vN   g [        U 5      n
S	nS
nUb  X:  aB   [        U
5      I S h  vN nX:  a  X-
  U	-  S	:X  a  US-  nSnU7v   OUS-  nUc  M;  X:  a  MB  U(       d  [        5       I S h  vN   g g  Ny NO! [         a    U(       d  [        5       I S h  vN     g f = f N47f)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                     [         R                  " [        [        U 5      5      nUS:  d  U[        R                  :  a  [        U5      eU$ ! [         a    [        U5      S ef = f)Nr   )rt   indexr$   r!   	TypeErrorr   sysmaxsize)rU   messager   s      r>   normalize_indexislice.<locals>.normalize_index  s^    	0NN4U#34E 19+W%%  	0W%4/	0s   $A A$r   FT)rU   objectr   strrC   int)r   lenslicer   r   r   r   r*   rQ   r`   r;   )rP   args
slice_argsstart_messagestop_messagestep_messager   r   r   r   r6   r   r   r}   s                 r>   r   r     s     EFF
4y1}CCIPQM?STTJ 	R  	X  KL	 # 	
Z--}= 
 ??" 	Z__l; 	 __$/*//<*X 	 qy&&qyEMl!HEO
,%,	!(O+G >u}49QJE"OMQJE ,%,  l / 	 ,! 	" l""		 	sl   CF
 E!F
>E EE %F
8F
?F
FF
E F<E?=FF
FF
c                 #    [        U 5      n [        U5      I S h  vN nSnU  S h  vN nSnX$4nUnU7v   M   N! [         a    [        5       I S h  vN     g f = f N7
 U(       d  [        5       I S h  vN    g g 7fr_   r   )rP   r6   previousr   r}   pairs         r>   r   r     s      !Hx(
 O! g"
 ) l
 l si   B? =? BA$A"A$B? AAABAB"A$$B9A<:Bc               >  #    [        U 5       Vs/ s S h  vN o"PM   N
 Os  snf nn[        U5      nUc  UnO1[        U[        5      (       d  [	        S5      eUS:  a  [        S5      e[        [        R                  " X15      5        S h  vN  nU7v   M  
 g 7f)NzExpected int as rr   zr must be non-negative)rQ   r   rL   r   r   r   r   r   )rP   r   r}   r   r   permutations         r>   r   r     s      3;82DEEwWEEDED	Ay3+,,	
Q122%i&<&<T&EF  k Gs?   B" 
 " "A)B
BBB
B)r   c               T  #    [         R                  " U 5      n U S:  a  [        S5      e/ nU H  n[        U5       Vs/ s S h  vN oDPM     [        [        R                  " USU 065        S h  vN nU7v   M   N8
 Os  snf nnUR	                  [        U5      5        Mv   N2
 g 7f)Nr   z"repeat argument cannot be negativer   )rt   r   r   rQ   r   r   r   r   )r   r   poolsrP   r}   r   rU   s          r>   r   r     s      ^^F#Fz=>>!#E6>x6HII7   	 1 15 H HI e	 JIIU4[!Is^   <B(B A?A=A?B!B(-B&1B$2B&5B(=A??B $B($B&&B(c               J  #    Uc   [        5       I S h  vN   U 7v   M  [        R                  " [        [        U5      5      nUS::  a  [        5       I S h  vN   g US:  a7  [        5       I S h  vN   US-  n[        5       I S h  vN   U 7v   US:  a  M6  g g  N NE N. N7f)Nr   r&   )r*   rt   r   r$   r!   r+   r)   )r}   times	remainings      r>   r   r   
  s     },M  tC/0IA~l
a-%'''Q	(***	 a- 
 	 	(*sL   B#BAB#BB#0B1B#B!B#B#B#B#!B#c                  #    Sn[        U5        S h  vN n[        U5       Vs/ s S h  vN oDPM   N N	
 Os  snf nnSnU " U6 I S h  vN  7v   MF  
 U(       d  [        5       I S h  vN    g g 7fr_   r   )r{   rP   result_yieldedargs_iterabler}   r   s         r>   r   r     sm      N'1 $m-5m-DEE'$EEEdO###  2
 l sV   A3A4AA3:868:A8:A3AA3+A.,A3c                   ^ [         R                  " [        [        U5      5      nUS:  a  [	        S5      eUS:X  a  g[        U 5      mT/nUR                  U4S j[        US-
  5       5       5        [        U5      $ )Nr   zn must be >= 0rA   c              3  :   >#    U  H  n[        T5      v   M     g 7fr8   )rf   ).0r   r6   s     r>   	<genexpr>tee.<locals>.<genexpr>9  s     G,Q&x00,s   r&   )	rt   r   r$   r!   r   rf   extendr   r   )rP   r   	iteratorsr6   s      @r>   r   r   .  sn     	tC|$A1u)**Av *H)1
IG%A,GGrJ   c                  #    Sn[        U5        S h  vN nU " U5      I S h  vN (       d  U(       d  [        5       I S h  vN     g SnU7v   MB   N= N/ N
 U(       d  [        5       I S h  vN    g g 7fr_   r   r   s       r>   r   r   =  si      O!(+ gw'''" l""'" , l sS   A5AAAA5AA5AA5AA5A5A5-A0.A5)	fillvaluec                 #    U Vs/ s H  n[        U5      PM     nn[        U5      nU(       d  [        5       I S h  vN   g S/U-  nSn / n[        U5       HF  u  pXX   (       d  UR	                  U 5        M!   [        U	5      I S h  vN n
UR	                  U
5        MH     Sn[        U5      7v   Mi  s  snf  N| N2! [         a2    SXX'   US-  nU(       d  U(       d  [        5       I S h  vN       g U n
 Nkf = f7f)NTFr&   )rQ   r   r*   	enumerater   r`   r;   r   )r   r   rP   r   
num_activeactivetuple_yieldedr   r   r6   rU   s              r>   r   r   Q  s      5>>I(#II>YJlVj FM
!(3OE=i("#Ho- MM% %  4( Fm/  ? 	 .% 	" %a
!((l**!	"sg   C=B5!C=B:<C=;B>	B<
B>-C=<B>>.C:,C/-C:2C=5C:7C=9C::C=)rP   r   rC   r[   )rv   r/   rw   r/   rC   r/   )rP   r   r{   zCallable[[T, T], Awaitable[T]]ry   zT | NonerC   r   )rP   r   r   r   r~   rV   rC   #AsyncGenerator[tuple[T, ...], None])rP   r   r   r   rC   r   )r   r   r   (Iterable[object] | AsyncIterable[object]rC   r   )r   r&   )r   r   r   r   rC   zAsyncGenerator[int, None])rP   r   rC   r   )r   z Callable[[T], Awaitable[object]]rP   r   rC   r   )rP   r   rC   z'AsyncGenerator[tuple[T, list[T]], None])rP   r   r   zCallable[[T], Awaitable[R]]rC   z'AsyncGenerator[tuple[R, list[T]], None]r8   )rP   r   r   z'Callable[[T], Awaitable[object]] | NonerC   z,AsyncGenerator[tuple[object, list[T]], None])rP   r   r   
int | NonerC   r   )r&   )
rP   r   r   r   r   r   r   r   rC   r   )rP   r   r   r   rC   r   )rP   r   rC   z!AsyncGenerator[tuple[T, T], None])rP   r   r   r   rC   r   )r   r   r   r   rC   r   )r}   r/   r   r   rC   r   )r{   zCallable[..., Awaitable[R]]rP   zlIterable[Iterable[object] | AsyncIterable[object]] | AsyncIterable[Iterable[object] | AsyncIterable[object]]rC   zAsyncGenerator[R, None])   )rP   r   r   r   rC   ztuple[AsyncIterator[T], ...])r   r   r   r   rC   z(AsyncGenerator[tuple[object, ...], None])A
__future__r   __all__r   rt   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   rQ   rS   rY   rf   rx   r   r   r   r   rH   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   rA   rJ   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$$ .$rJ   