a ÁQ\aã@s€dZddlmZmZddlmZmZmZmZm Z ddl m Z dgZ edƒZ Gdd „d ƒZegee fee d fd œd d„Zd S) z& Implementation for async generators. é)ÚQueueÚget_event_loop)ÚAsyncGeneratorÚCallableÚIterableÚTypeVarÚUnioné)Úrun_in_executor_with_contextÚgenerator_to_async_generatorÚ_Tc@s eZdZdS)Ú_DoneN)Ú__name__Ú __module__Ú __qualname__©rrúGlib/python3.9/site-packages/prompt_toolkit/eventloop/async_generator.pyr sr N)Ú get_iterableÚreturncs„d‰tƒ‰tƒ‰tƒ‰ddœ‡‡‡‡‡fdd„ }t|ƒ}z6ˆ ¡IdH}t|tƒrVq^q:|Vq:Wd‰|IdHnd‰|IdH0dS)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 sJz4ˆƒD]}ˆrq$ˆ ˆj|¡qWˆ ˆjˆ¡nˆ ˆjˆ¡0dS)z~ Consume the generator in background thread. When items are received, they'll be pushed to the queue. N)Zcall_soon_threadsafeZ put_nowait)Úitem©Z_donerZloopÚqZquittingrrÚrunner%s  z,generator_to_async_generator..runnerT)r rrr ÚgetÚ isinstance)rrZrunner_frrrrr s    ù)Ú__doc__ZasynciorrÚtypingrrrrrZutilsr Ú__all__r r r rrrrÚs ÿ þ