Xj(?UddlmZdZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z ddlmZmZddlmZmZmZmZmZddlmZdd lmZdd lmZmZmZed Zed Z e!Z"ed Gdde eZ#d7dZ$ed GddeeZ%ed GddeeZ&Gdde eZ'd8dZ(e(fdd d9dZ)d d d:dZ*GddZ+e+Z,de-d< d;d Z. d;d!Z/ dd#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/ dKd0Z9dCdLd1Z: dMd2Z; dN dOd3Z< d@d4Z=dd5 dPd6Z>y)Q) annotations) accumulatebatchedChain combinationscombinations_with_replacementcompresscountcycle dropwhile filterfalsegroupbyislicepairwise permutationsproductrepeatstarmaptee takewhile zip_longestN)AsyncGenerator AsyncIterable AsyncIterator AwaitableCallableIterableIterator) dataclassfield)AnyGenericTypeVarcastoverload)Lock) CancelScope)cancel_shielded_checkpoint checkpointcheckpoint_if_cancelledTRF)eqc eZdZUded<ddZy)_IterableAsyncIteratorz Iterator[T]iteratorcKtd{ t|j}t d{|S7.#t$rt d{7t dwxYw7/wN)r+nextr1 StopIterationr)StopAsyncIteration)selfresults c/mnt/ssd/data/Dropbox/adrian/vault-secondbrain/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*Nreturnr,)__name__ __module__ __qualname____annotations__r:r9r0r02s  rBr0ct|tr|St|tr|jSt t |Sr3) isinstancerr __aiter__r0iteriterables r9_iteraterIBs9(M*(M*!!## !$x. 11rBc8eZdZUdZded<dZded<dZded<y) _TeeLinkNz object | Nonevaluez_TeeLink[T] | Noner4Fboolfilled)r=r>r?rLr@r4rNrArBr9rKrKLs!E=#D #FDrBrKc<eZdZUded<eeZded<ddZy) _TeeStateAsyncIterator[T]r1)default_factoryr'lockcK|jry|j4d{|jr dddd{yt|jtd{|_|j turt |_d|_ dddd{y77h7G7 #1d{7swYyxYwwNFT)rNrSanextr1_tee_endrLrKr4)r7links r9fillz_TeeState.fillXs ;;99  {{    %T]]H==DJzz)$J DK    >    sqCB$CB, CB&CB, B(!2B, CB*C&C(B,*C,B>2B5 3B>:CN)rX _TeeLink[T]r<rM)r=r>r?r@r r'rSrYrArBr9rPrPSst,D$, rBrPcDeZdZUded<ded<ded< d dZd dZy ) _TeeAsyncIteratorz _TeeState[T]_staterZ_linkrM_element_yieldedct|tr*|j|_|j|_d|_yt t ||_t |_d|_y)NF)rDr\r]r^rPrIrKr_)r7rHs r9__init__z_TeeAsyncIterator.__init__msS h 1 2"//DK!DJ !&$HX$67DK!DJ %rBcK|jj|jd{}|jjtur$|j st d{t|std{d|_tt|jj}|jj}|J||_|std{|S777j7 w)NT) r]rYr^rLrWr_r*r6r+r$r,r4r))r7had_yieldpointrL next_links r9r:z_TeeAsyncIterator.__anext__ys#{{// ;; ::  x '(( l""$ $)+ + + $Q (()JJOO $$$ ,. . . %<# , /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\c6Ktj||Swr3)operatoradd)xys r9 _operator_addrks <<1 s)initialcDKt|}| t|d{}n&t d{|}t d{||23d{}|||d{}| 7R#t$rtd{7YywxYw7c7Q7C746ywr3)rIrVr6r*r+r))rHfunctionrlr1totalelements r9rrs !H /)E &'''(*** K!gug.. *! ,     (*."sB A4A2A4B BB B B BBB B 'B( B 2A44B B  BB BB B BB B )strictcVK|dkr tdt|} g}t|D]%} |jt |d{'t|D7#t $r8|st d{7Yy|r tddt|YywxYww)Nr&zn must be at least onezbatched(): incomplete batch) ValueErrorrIrangeappendrVr6r*tuple)rHnrqr1batch_s r9rrs 1u122!H q A  5?23 El 3% $,&&$%BCMEl" sR-B)A% A# A%B)#A%%B&=B>B&B)B&"B)%B&&B)c,eZdZ ddZ ddZy)rc$|j|Sr3) from_iterable)r7 iterabless r9__call__zChain.__call__s!!),,rBcKd}t|} |23d{}t|23d{}d}|7 76+6 t|dd}|xtd5|d{7dddnR#1swYnIxYw#t|dd}|2td5|d{7dddw#1swYwxYwwxYw|std{7yyw)NFTaclose)shield)rIgetattrr(r*)r7r}element_yielded outer_iterrHrprs r9r|zChain.from_iterables i(  #", " "h%-h%7""'&*O!M ""%7#- Z48F! -# (NN###Z48F! -# (NN###",  sCB>8> B<:< B><BC A5&A)'A5, C5A>:CC B7(B+ )B7. C7C <CCCCN)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|rArBr9rrs0-8- -  < ! rBrchaincKt|2cgc3d{}| 76ncc}w}}ttj||23d{7}|6ywr3)rI itertoolsrrHrrppool combinations r9rrsW3;82DEEwWEEEDE%i&<&A"   " "'AA A A AcKt|2cgc3d{}| 76ncc}w}}ttj||23d{7}|6ywr3)rIrrrs r9rrsX3;82DEEwWEEEDE%i&M&MdTU&VWkXrcKt|}t|}d} t|d{}t|d{}|rd}|17!7#t$r|std{7YywxYwwrUrIrVr6r*)data selectors data_iteratorselector_iteratorrdatumselectors r9r r s~TNM +O   ..E"#455H "OK .5! " l""   sTA5AA AAA A5 AAA2)A,*A2/A51A22A5czK|} td{|}||z }td{|17#7 wr3)r+r))startsteprwrLs r9r r sG A %''' T (*** ' +s;7;9 ;;cKg}t|23d{}|j|| 76|std{7y |D]}td{7| wr3)rIrur*)rHsavedrps r9r r suE!(+g W + l  G,  M  s7A*202A*2A*AA*A A*cKd}d}t|23d{}|r||d{rd}d}|&7!76|std{7yywrUrIr*) predicaterHrdroppingrps r9r r +slOH!(+g i000  0, l s9A<8<A:A<AA A AcKd}t|23d{}||d{rd}|"776|std{7yywrUrrrHrrps r9r r >s]O!(+gw'''"OM', l s>A626 A4AA6AAA Acyr3rArGs r9rrMs/2rBcyr3rA)rHkeys r9rrSs/2rBcfKt|} t|d{}||n||d{}|g}|23d{}||n||d{}||k7r||f}|}|g}|1|j |C7`#t$rtd{7YywxYw7p7d7R6||fywr3)rIrVr6r*ru)rHrr1rp group_keyvaluesnext_keycompleted_groups r9rrZs!Hh' ;#g,,>IYF!##g!k7S\/A y '/O IYF! ! MM' "!( l-?#/A" V s B1BA>BB1B" B1B(B$B(B1B&*B1>BBBBB1BB1$B(&B1( B1cyr3rA)rHstops r9rrus "rBcyr3rA)rHrrrs r9rr}s"rBcK|s tdt|dkDrtdt|dzt|}d}d}d}d d}|jd n||j|}|jdn||j|}|j dn||j |} | d kr t ||d k(s||k(rtd{yt|} d } d } || |kr? t| d{} | |k\r| |z | zd k(r | dz } d } | n| dz } |9| |kr?| std{yy7p7G#t$r| std{7YywxYw7.w) Nz+islice expected at least 2 arguments, got 1z)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 jkDr t ||S#t$r t |dwxYw)Nr)rgindexr$r! TypeErrorrssysmaxsize)rLmessagers r9normalize_indexzislice..normalize_indexs^ 0NN4U#34E 19 +W% %  0W%4 / 0s #A A rFT)rLobjectrstrr<int) rlenslicerrrrsr*rIrVr6)rHargs slice_args start_message stop_message step_messagerrrrr1rrrps r9rrs EFF 4y1}CCIPQM?STTJ R XKL     # Z--} =  ?? " Z__l ; __ $/*//<*X  qy&& qyETMl!H EO ,%$, !(O+G E>uu}49 QJE"OM QJE ,%$, l / ,! " l""    slCE/EE/1E ?EE $E/)E//E/>E-?E/E E*!E$"E*'E/)E**E/cKt|} t|d{}d}|23d{}d}||f}|}|7#t$rtd{7YywxYw766|std{7yywrUr)rHr1previousrrppairs r9rrs!Hx( O!g'" ) l  l si A;?=?A;A#A!A#A;?AAAA;AA;!A##A;3A64A;c.Kt|2cgc3d{}| 76ncc}w}}t|}||}n+t|ts t d|dkr t dtt j||23d{7}|6yw)NzExpected int as rrzr must be non-negative)rIrrDrrrsrr)rHrrprrw permutations r9rrs3;82DEEwWEEEDE D Ay  3 +,, Q122%i&<&>!#E"6>x6HII7" 1 15 H HIe JIII U4[!Is]:B"A<A:A8 A:A< B")B -B.B 1B"8A::A<;#B"B  B"c<K| td{|tjtt|}|dkrtd{y|dkDr5t d{|dz}t d{||dkDr4yy77B7,7w)Nrr&)r*rgrr$r!r+r))rptimes remainings r9rrs },  MtC/0IA~l a-%'''Q (*** a-   (*sKBB?BBB+B,BBBBBBBcKd}t|23d{}t|2cgc3d{}| 77 6ncc}w}}d}||d{7E6|std{7yywrUr)rnrHresult_yielded args_iterablerprs r9rrsxN'1$$m-5m-DEE'$EEEEdO### 2 l sVA-A4AA-:86 8:A8:A- A A-%A(&A-ctjtt|}|dkr t d|dk(ryt |g}|j fdt|dz Dt|S)Nrzn must be >= 0rAc34K|]}tywr3)r\).0ryr1s r9 ztee..6sGQ&x0Gsr&) rgrr$r!rsr\extendrtrv)rHrw iteratorsr1s @r9rr+sn tC|$A1u)**Av *H)1 I G%A,GG  rBcKd}t|23d{}||d{s|std{yd}|7727$76|std{7yywrUrrs r9rr:srO!(+gw'''" l""  '", l sQA%A AA  A%A A%A A%A  A% A% A%A A%) fillvaluecK|Dcgc] }t|}}t|}|std{ydg|z}d} g}t|D]A\}} ||s|j | t | d{} |j | Cd}t|bcc}w7u7/#t $r)d||<|dz}|s|std{7Yy|} Y^wxYww)NTFr&)rIrr* enumeraterurVr6rv) rr}rHr num_activeactive tuple_yieldedrrr1rLs r9rrNs5>>(#>I>YJ lVj FM !(3 !OE8%= i( "#Ho- MM% % !( Fm/ ? .% " %u a !((l**! "sgC$B&C$B+8C$/B/=B->B/*C$-B//$C!CC!C$C!C$ C!!C$)rHrr<rQ)rir,rjr,r<r,)rHrrnzCallable[[T, T], Awaitable[T]]rlzT | Noner<r)rHrrwrrqrMr<#AsyncGenerator[tuple[T, ...], None])rHrrrr<r)rrr(Iterable[object] | AsyncIterable[object]r<r)rr&)rrrrr<zAsyncGenerator[int, None])rHrr<r)rz Callable[[T], Awaitable[object]]rHrr<r)rHrr<z'AsyncGenerator[tuple[T, list[T]], None])rHrrzCallable[[T], Awaitable[R]]r<z'AsyncGenerator[tuple[R, list[T]], None]r3)rHrrz'Callable[[T], Awaitable[object]] | Noner<z,AsyncGenerator[tuple[object, list[T]], None])rHrr int | Noner<r)r&) rHrrrrrrrr<r)rHrrrr<r)rHrr<z!AsyncGenerator[tuple[T, T], None])rHrrrr<r)r}rrrr<r)rpr,rrr<r)rnzCallable[..., Awaitable[R]]rHzlIterable[Iterable[object] | AsyncIterable[object]] | AsyncIterable[Iterable[object] | AsyncIterable[object]]r<zAsyncGenerator[R, None]))rHrrwrr<ztuple[AsyncIterator[T], ...])r}rrrr<z(AsyncGenerator[tuple[object, ...], None])? __future__r__all__rrgrcollections.abcrrrrrrr dataclassesrr typingr!r"r#r$r%_core._synchronizationr' _core._tasksr(lowlevelr)r*r+r,r-rrWr0rIrKrPr\rkrrrrr@rrr r r r r rrrrrrrrrrrArBr9rs" . )88(%UU CL CL 8 e ]1-  2 ewqz  e ($ a($N 0= ,,   4IN,14AE(4>wu,14(,14( (7.,$/,& / ,   2,2,2 2  2,2 $2-2 248, 026 "," " " "  "," " "  "  " "H,H HHV,&,?C , 1; ( "?@ . 8; (  $) B  &89 , 14 ! /,,$8$$.$rB