Dh .dZddlZddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z mZddlmZmZddlmZmZmZmZddde eed e ed eefd Zd d de eeded eefdZd dddeededed e efdZ ddeeededed e efdZy)zt Friendlier version of asyncio standard library. Provisional library. Must be imported as `aioitertools.asyncio`. N) AnyAsyncGenerator AsyncIterable AwaitablecastDictIterableListOptionalSetTuple)iter maybe_await) AnyIterable AsyncIteratorMaybeAwaitableT)timeoutawsrreturncKt}|Dchc]}tj|}}d}|r|dkDrtj|z}nd}|r|rbtjz }|dkrF|D]-}t |tj r|j ./tjttttttttftj||tjd{\}}|D]}|d{|ryycc}w7)7w)a Run awaitables in `aws` concurrently, and yield results as they complete. Unlike `asyncio.as_completed`, this yields actual results, and does not require awaiting each item in the iterable. Cancels all remaining awaitables if a timeout is given and the timeout threshold is reached. Example:: async for value in as_completed(futures): ... # use value immediately Nr)r return_when)setasyncio ensure_futuretime isinstanceFuturecancel TimeoutErrorrr r rrwaitFIRST_COMPLETED) rrdoneapending remaining thresholdfutitems v/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/aioitertools/asyncio.py as_completedr,s%("eDDG!Hq'"7"7":!HG!H!%I7Q;IIK')   !DIIK/IA~"C!#w~~6   **,, #il#S1%66 7,,!#33  g D*  7 "I8 s4ED9C'ED> E*E+ E7EEF)return_exceptions iterablesr-c  Ktj tj dttddf fd }|Dcgc]}tj||}}t |} |r5 j }|r|n| j }||r5|D]#}|jr|j%|D] } |d{ycc}w#tj$rYnwxYw#tj$rSt|D]$}|js|j|&tjdd{7YwxYw#tjtf$rYwxYw7#tj$rYwxYw#|D]#}|jr|j%|D]'} |d{7#tj$rY%wxYwwxYww)ao Yield results from one or more async iterables, in the order they are produced. Like :func:`as_completed`, but for async iterators or generators instead of futures. Creates a separate task to drain each iterable, and a single queue for results. If ``return_exceptions`` is ``False``, then any exception will be raised, and pending iterables and tasks will be cancelled, and async generators will be closed. If ``return_exceptions`` is ``True``, any exceptions will be yielded as results, and execution will continue until all iterables have been fully consumed. Example:: async def generator(x): for i in range(x): yield i gen1 = generator(10) gen2 = generator(12) async for value in as_generated([gen1, gen2]): ... # intermixed values yielded from gen1 and gen2 rrNc<K |23d{}j|d{#776y#tj$r+t|tr|j d{7t $r$}j|d{7Yd}~yd}~wwxYww)N)putrCancelledErrorrraclose Exception)rr*e exc_queuequeues r+tailerzas_generated..tailerzs #" & &diio%% &%#%% $/kkm##  #--" " " #sgB0.*.0,0.00B6B&A)'B5B B  BBBBgMbP?)rQueuerrrr get_nowait QueueEmptylistr$removesleepr2 GeneratorExitr ) r.r-r8rtasksr&excvaluetaskr6r7s @@r+ as_generatedrDZs:+2--/I%mmoE #=+ # #>G GTW " "6$< 0 GE G%jG  **,$II  +((* . D99;   D   ? H%%   %% + M-Dyy{t,-mmE***  +  " "M 2   ))   D99;   D  ))   sAH"C)) H7E0:C.E0D+E0.HHF!F"F&H.DE0DE01E-9+E-$E'%E-*E0,E--E00F  F* F  F*FF'$H&F''H*HHG%G! G%$H%G; 8H:G; ;HHr-limitargsrGcKi}i}dgt|z}t}t}d} |t|kr|dk(st||kr~|||vr|||j|n7tj||} |j | ||| <|g|||<|dz }|t|kr|dk(rot||kr~|rx tj |tjd{\}}|D]A} |r'| jr| j||| <,| j||| <C |s|t|k(rn,|jD]*} tdt| D]} || d|| | <,|S7#tj$r7|D]} | jtj|ddid{7wxYww)aR Like asyncio.gather but with a limit on concurrency. Note that all results are buffered. If gather is cancelled all tasks that were internally created and still pending will be cancelled as well. Example:: futures = [some_coro(i) for i in range(10)] results = await gather(*futures, limit=2) NrTrEr)rr-)lenrappendrraddr"r# exceptionresultr2r gathervaluesrange) r-rGrH input_mapposretr&r$next_argrCxlstis r+rOrOs*02I(*CVc$i'C&)eG#&5DH T" s7|e7KH~*$x.)00: +2*?*?X*O D!$D -5J $x.) MHT" s7|e7K&  &-ll)@)@'! g1A(Q[[]&'kkmCF &'hhjCF 18s4y0 O R!&q#c(# &Ac!f+CAK && J/!))  AHHJnngFFFF  sKB:G'=G' G'(F7F8A FAG'FAG$GG$$G'itrcKtt|2cgc3d{}t|76ncc}wc}||dd{7Sw)z Wrapper around gather to handle gathering an iterable instead of ``*args``. Note that the iterable values don't have to be awaitable. NrF)rOaiterr)rYr-rGrXs r+ gather_iterr\sE(-c 3 31+a. 3 3 3+  s2A0. ,. 0. 0AAA)FrE)__doc__rrtypingrrrrrrr r r r r builtinsrr[rtypesrrrrfloatr,boolrDintrOr\r+rfs"      1@@ $9 )A, 9e_91 9~$N a()NN1 Nf$L Q<LL L #Y Lb$ ^A& '  !W re