o [h@sddlZddlZddlZddlZddlmZmZmZzddlZWn ey+dZYnwej dkr8ddlm Z nddlm Z e dZ dejejefddfd d Zd ejd e fdejd ejde fddZGdddeZdedefddZdedefddZdS)N)AnyAsyncGeneratorIterator) create_task) ensure_futureTargsreturncsJdd|D}tj|tjdIdH\}}dd|Ddd|DdS)NcSs"g|] \}}t|di|qS)r).0handlerkwargsr r |/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/starlette/concurrency.py s"z,run_until_first_complete..)Z return_whencSg|]}|qSr )cancelrtaskr r rrcSrr )resultrr r rrr)asynciowaitZFIRST_COMPLETED)r tasksdonependingr r rrun_until_first_completes rfunc.rcspt}tdur tj|g|Ri|}t}|j}|f}n |r+tj|fi|}|jd|g|RIdHSN)rZget_event_loop contextvars functoolspartialZ copy_contextrunZrun_in_executor)rr rloopchildcontextr r rrun_in_threadpoolsr(c@s eZdZdS)_StopIterationN)__name__ __module__ __qualname__r r r rr)+sr)iteratorcCszt|WStytwr )next StopIterationr)r-r r r_next/s   r1cCs2 z tt|IdHVWn tyYdSwqr )r(r1r)r0r r riterate_in_threadpool9s r2)rr"systypingrrrr! ImportError version_inforr TypeVarr TupleCallabledictrr( Exceptionr)r1r2r r r rs6