U Ôðccã@s€dZddlmZddlmZmZmZmZmZddl m Z m Z dgZ edƒZ Gdd „d ƒZegee fee d fd œd d„Zd S) z& Implementation for async generators. é)ÚQueue)ÚAsyncGeneratorÚCallableÚIterableÚTypeVarÚUnioné)Úget_event_loopÚrun_in_executor_with_contextÚgenerator_to_async_generatorÚ_Tc@s eZdZdS)Ú_DoneN)Ú__name__Ú __module__Ú __qualname__©rrúb/var/www/html/project/venv/lib/python3.8/site-packages/prompt_toolkit/eventloop/async_generator.pyr sr N)Ú get_iterableÚreturncsvd‰tƒ‰tƒ‰tƒ‰ddœ‡‡‡‡‡fdd„ }t|ƒ}z(ˆ ¡IdH}t|tƒrVq^q:|Vq:W5d‰|IdHXdS)zÝ 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. FN)rc s<z&ˆƒD]}ˆrq$ˆ ˆj|¡qW5ˆ ˆjˆ¡XdS)z~ Consume the generator in background thread. When items are received, they'll be pushed to the queue. N)Úcall_soon_threadsafeÚ put_nowait)Úitem©Ú_donerÚloopÚqZquittingrrÚrunner%s  z,generator_to_async_generator..runnerT)r rr r ÚgetÚ isinstance)rrZrunner_frrrrr s   )Ú__doc__ÚasynciorÚtypingrrrrrÚutilsr r Ú__all__r r r rrrrÚs ÿ þ