`iY@ddlmZdZdZGddeZdZdS)wrapsc<tfd}|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. c6|i|}t||S)N)next)argskwargsgfuncs _/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ijson/utils.pywrapperzcoroutine..wrapper s' D$ !& ! ! Qr)r r s` r coroutiners5  4[[[ Nrc4|}|D]\}}}||g|Ri|}|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`. )sink coro_pipelinef coro_func coro_args coro_kwargss r chainrsE A-:44) 9k Ia 3) 3 3 3{ 3 3 Hrc eZdZdZejZdS) 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__listappendsendrrr rr!s! ;DDDrrc'dKt}t|g|R} |D]_} ||n8#t$r+}|D]}|Vt |t rYd}~dSd}~wwxYw|D]}|V|dd=`dS#t $r" |YdS#YYdSxYwwxYw)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! Exception isinstance StopIteration GeneratorExitclose)sourcereventsrvalueexevents r coros2genr--s' __F f%}%%%A  E u    #  EKKKKb-00FFFFFF       qqq      GGIIIIII  DDD sOB:B A/A*"B)A**A//B B/B%%B+'B/+B/N) functoolsrrrrrr-rrr r/sx            D   r