U ×€»d ã@s8ddlmZdd„Zdd„ZGdd„deƒZdd „Zd S) é©Úwrapscstˆƒ‡fdd„ƒ}|S)zè Wraps a generator which is intended to be used as a pure coroutine by .send()ing it values. The only thing that the wrapper does is calling .next() for the first time which is required by Python generator protocol. csˆ||Ž}t|ƒ|S)N)Únext)ÚargsÚkwargsÚg©Úfunc©ú^/mounts/lovelace/software/anaconda3/envs/rescript-2/lib/python3.8/site-packages/ijson/utils.pyÚwrapper s zcoroutine..wrapperr)r r r rr Ú coroutinesr cGs(|}|D]\}}}||f|ž|Ž}q|S)aT Chains together a sink and a number of coroutines to form a coroutine pipeline. The pipeline works by calling send() on the coroutine created with the information in `coro_pipeline[-1]`, which sends its results to the coroutine created from `coro_pipeline[-2]`, and so on, until the final result is sent to `sink`. r )ÚsinkÚ coro_pipelineÚfZ coro_funcZ coro_argsZ coro_kwargsr r r Úchainsrc@seZdZdZejZdS)Ú sendable_lista[ A list that mimics a coroutine receiving values. Coroutine are sent values via their send() method. This class defines such a method so that values sent into it are appended into the list, which can be inspected later. As such, this type can be used as an "accumulating sink" in a pipeline consisting on many coroutines. N)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚlistÚappendÚsendr r r r r!src gsªtƒ}t|f|žŽ}zb|D]X}z| |¡Wn*tk rV|D] }|Vq@YWdSX|D] }|Vq\|dd…=qWn.tk r¤z | ¡Wn YnXYnXdS)z¡ A utility function that returns a generator yielding values dispatched by a coroutine pipeline after *it* has received values coming from `source`. N)rrrÚ StopIterationÚ GeneratorExitÚclose)ÚsourcerÚeventsrÚvalueÚeventr r r Ú coros2gen-s$  r!N)Ú functoolsrr rrrr!r r r r Ús