
    Cj(?                       % 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  \" S5      r\" S5      r \!" 5       r"\" SS9 " S S\	\   5      5       r#S7S jr$\" SS9 " S S\\   5      5       r%\" SS9 " S S\\   5      5       r& " S S\	\   5      r'S8S jr(\(4SS.       S9S jjjr)SS.       S:S jjr* " S S5      r+\+" 5       r,S\-S'         S;S  jr.      S;S! jr/      S<S" jr0S=S>S# jjr1    S?S$ jr2      S@S% jr3      S@S& jr4\    SAS' j5       r5\      SBS( j5       r5 SC     SDS) jjr5\      SES* j5       r6\ SF         SGS+ jj5       r6      SHS, jr6    SIS- jr7 SC     SJS. jjr8SS/.     SKS0 jjr9SCSLS1 jjr:      SMS2 jr; SN     SOS3 jjr<      S@S4 jr=SS5.     SPS6 jjr>g)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                  *    \ rS rSr% S\S'   SS jrSrg)_IterableAsyncIterator2   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+   nextr2   StopIterationr)   StopAsyncIteration)selfresults     a/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/anyio/itertools.py	__anext__ _IterableAsyncIterator.__anext__6   sf     %'''	/$--(F
 )*** 	(  	/,...$$.	/ 	+s:   A+?A+A A+A)A+A&AA&&A+ Nreturnr,   )__name__
__module____qualname____firstlineno____annotations__r;   __static_attributes__r=       r:   r0   r0   2   s    	rF   r0   c                    [        U [        5      (       a  U $ [        U [        5      (       a  U R                  5       $ [	        [        U 5      5      $ r4   )
isinstancer   r   	__aiter__r0   iteriterables    r:   _iteraterM   B   s?    (M**(M**!!##!$x.11rF   c                  @    \ rS rSr% SrS\S'   SrS\S'   SrS\S	'   S
rg)_TeeLinkL   Nzobject | Nonevaluez_TeeLink[T] | Noner5   Fboolfilledr=   )	r@   rA   rB   rC   rQ   rD   r5   rS   rE   r=   rF   r:   rO   rO   L   s!    E=#D
#FDrF   rO   c                  @    \ rS rSr% S\S'   \" \S9rS\S'   S
S jrSr	g	)	_TeeStateS   AsyncIterator[T]r2   )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)rS   rY   anextr2   _tee_endrQ   rO   r5   )r8   links     r:   fill_TeeState.fillX   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r=   N)r^   _TeeLink[T]r?   rR   )
r@   rA   rB   rC   rD   r    r'   rY   r_   rE   r=   rF   r:   rU   rU   S   s    t,D$,rF   rU   c                  P    \ rS rSr% S\S'   S\S'   S\S'       SS jrSS	 jrS
rg)_TeeAsyncIteratorh   z_TeeState[T]_statera   _linkrR   _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)rH   rc   re   rf   rU   rM   rO   rg   )r8   rL   s     r:   __init___TeeAsyncIterator.__init__m   sJ     h 122"//DK!DJ#HX$67DK!DJ %rF   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)re   r_   rf   rQ   r]   rg   r*   r7   r+   r$   r,   r5   r)   )r8   had_yieldpointrQ   	next_links       r:   r;   _TeeAsyncIterator.__anext__y   s     #{{//

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

(()JJOO	$$$
,...% < #
 , /sF   )C>C6?C>+C8,C>
C:A$C>/C<0C>8C>:C><C>)rg   rf   re   N)rL   z5Iterable[T] | AsyncIterable[T] | _TeeAsyncIterator[T]r?   Noner>   )r@   rA   rB   rC   rD   ri   r;   rE   r=   rF   r:   rc   rc   h   s.    
&M
&	
&rF   rc   c                6   #    [         R                  " X5      $ 7fr4   )operatoradd)xys     r:   _operator_addru      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r4   )rM   r\   r7   r*   r+   r)   )rL   functionrv   r2   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)
ValueErrorrM   rangeappendr\   r7   r*   tuple)rL   nr{   r2   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      $ r4   )from_iterable)r8   	iterabless     r:   __call__Chain.__call__   s     !!),,rF   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)rM   getattrr(   r*   )r8   r   element_yielded
outer_iterrL   rz   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+r=   N)r   Iterable[T] | AsyncIterable[T]r?   AsyncGenerator[T, None])r   zXIterable[Iterable[T] | AsyncIterable[T]] | AsyncIterable[Iterable[T] | AsyncIterable[T]]r?   r   )r@   rA   rB   rC   r   r   rE   r=   rF   r:   r   r      s0    -8-	 -
< 
!rF   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r4   )rM   	itertoolsr   rL   rrz   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r4   )rM   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[   rM   r\   r7   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r4   )r+   r)   )startstepr   rQ   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r4   )rM   r   r*   )rL   savedrz   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[   rM   r*   )	predicaterL   r   droppingrz   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   rL   r   rz   s       r:   r   r   >  sU      O!(+ gw'''"OM' ,
 l s>   A=9=A;A	A=AAAAc                    g r4   r=   rK   s    r:   r   r   M  s     /2rF   c                    g r4   r=   )rL   keys     r:   r   r   S  s     /2rF   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r4   )rM   r\   r7   r*   r   )rL   r   r2   rz   	group_keyvaluesnext_keycompleted_groups           r:   r   r   Z  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 r4   r=   )rL   stops     r:   r   r   u  s    
 "rF   c                   g r4   r=   )rL   r   r   r   s       r:   r   r   }  s     "rF   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 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                     [         R                  " [        [        U 5      5      nUS:  d  U[        R                  :  a  [        U5      eU$ ! [         a    [        U5      S ef = f)Nr   )rq   indexr$   r!   	TypeErrorr}   sysmaxsize)rQ   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)rQ   objectr   strr?   int)r   lenslicer   r   r   r}   r*   rM   r\   r7   )rL   args
slice_argsstart_messagestop_messagestep_messager   r   r   r   r2   r   r   rz   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   )rL   r2   previousr   rz   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)rM   r   rH   r   r   r}   r   r   )rL   r   rz   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   )rq   r   r}   rM   r   r   r   r   )r   r   poolsrL   rz   r   rQ   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*   rq   r   r$   r!   r+   r)   )rz   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   )rx   rL   result_yieldedargs_iterablerz   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 >= 0r=   c              3  :   >#    U  H  n[        T5      v   M     g 7fr4   )rc   ).0r   r2   s     r:   	<genexpr>tee.<locals>.<genexpr>6  s     G,Q&x00,s   r&   )	rq   r   r$   r!   r}   rc   extendr~   r   )rL   r   	iteratorsr2   s      @r:   r   r   +  sn     	tC|$A1u)**Av *H)1
IG%A,GGrF   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&   )rM   r   r*   	enumerater   r\   r7   r   )r   r   rL   r   
num_activeactivetuple_yieldedr   r   r2   rQ   s              r:   r   r   N  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=)rL   r   r?   rW   )rs   r,   rt   r,   r?   r,   )rL   r   rx   zCallable[[T, T], Awaitable[T]]rv   zT | Noner?   r   )rL   r   r   r   r{   rR   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]r4   )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   )rz   r,   r   r   r?   r   )rx   zCallable[..., Awaitable[R]]rL   zlIterable[Iterable[object] | AsyncIterable[object]] | AsyncIterable[Iterable[object] | AsyncIterable[object]]r?   zAsyncGenerator[R, None])   )rL   r   r   r   r?   ztuple[AsyncIterator[T], ...])r   r   r   r   r?   z(AsyncGenerator[tuple[object, ...], None])?
__future__r   __all__r   rq   r   collections.abcr   r   r   r   r   r   r   dataclassesr   r    typingr!   r"   r#   r$   r%   _core._synchronizationr'   _core._tasksr(   lowlevelr)   r*   r+   r,   r-   r   r]   r0   rM   rO   rU   rc   ru   r   r   r   r   rD   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   r=   rF   r:   <module>r      s   ".   
   ) 8 8 ( % U UCLCL8 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   