+ j,i]a0t$Rt^RIHt^RIHt^RIHt^RIH t H t H t ^RI H t HtHtHtHt^RIHtRR.t]!R ]] R 3,R 7t]R R l4tRtR]R&]!R4t!RR4t]3RRlltR #)z& Implementation for async generators. ) annotations)get_running_loop)asynccontextmanager)EmptyFullQueue)AnyAsyncGeneratorCallableIterableTypeVar)run_in_executor_with_contextaclosinggenerator_to_async_generator _T_GeneratorN)boundc V^8dQhRRRR/#)thingrreturnz"AsyncGenerator[_T_Generator, None])formats"J/usr/lib/python3/dist-packages/prompt_toolkit/eventloop/async_generator.py __annotate__rs 'c"V5xVP4GRjxL R#L TP4GRjxL i;i5i)z1Similar to `contextlib.aclosing`, in Python 3.10.N)aclose)rs&rrrs-  llnellns+A%A#AA<AAiintDEFAULT_BUFFER_SIZE_Tc]tRt^1tRtR#)_DonerN)__name__ __module__ __qualname____firstlineno____static_attributes__rrrr!r!1srr!c$V^8dQhRRRRRR/#)r get_iterablezCallable[[], Iterable[_T]] buffer_sizerrzAsyncGenerator[_T, None]r)rs"rrr5s+HH,HHHrc~aaa"Ro\VR7o\4pRVVV3Rllp\V4pSP4p\V\4'dMV5xK0RoVGRjxL R# \d)TP RSP 4GRjxL pL^i;iL< RoTGRjxL i;i5i)aA Turn a generator or iterable into an async generator. This works by running the generator in a background thread. :param get_iterable: Function that returns a generator or iterable when called. :param buffer_size: Size of the queue between the async consumer and the synchronous generator that produces items. F)maxsizecV^8dQhRR/#)rrNoner)rs"rr2generator_to_async_generator..__annotate__HsDrc<S!4F@pS'd!SP\4^R7R#SPV^R7KB SP\4^R7R# \dS'dR#Kpi;i \dKS'd?SP\4^R7R# \dS'dR#K8i;iKi;i \dS'dR#Ki;i SP\4^R7i \dS'dR#K9i;i;i)zf Consume the generator in background thread. When items are received, they'll be pushed to the queue. )timeoutN)putr!r)itemr(qquittings rrunner,generator_to_async_generator..runnerHsA  $EE%'1E- 'dA. '"EE%'1E-   !#" EE%'1E-  !!EE%'1E-  sC?A-C?B  C?C"-BB CC?!B>>CCC?CC?"C<;C<?D=DD=D:1D=6D=9D::D=TN) rrr get_nowaitrrun_in_executorget isinstancer!)r(r)loopr5runner_fr2r3r4sf& @@rrr5sH 5A  DD,F3H ?||~$&&  ?!11$>>> ?  si/B=B+A3B+%B=,B)-B=3*B&B B&#B+%B&&B+)B=+B:3B64B::B=)__conditional_annotations____doc__ __future__rasyncior contextlibrqueuerrrtypingrr r r r utilsr __all__rrr__annotations__rr!r)r=s@rrGs#$*$$CC/"  ~^CI-FG * S T]  +HHr