a xd@sHddlZddlmZddlmZGdddZGdddZd d ZdS) N)wraps)isasyncgenfunctionc@s$eZdZddZddZddZdS)aclosingcCs ||_dSN_aiter)selfZaiterr M/var/www/html/Ranjet/env/lib/python3.9/site-packages/async_generator/_util.py__init__szaclosing.__init__cs|jSrrr r r r __aenter__ szaclosing.__aenter__cs|jIdHdSr)raclose)r argsr r r __aexit__ szaclosing.__aexit__N)__name__ __module__ __qualname__r rrr r r r rsrc@s4eZdZddZddZddZddZd d Zd S) _AsyncGeneratorContextManagercCs |j|_||i||_dSr)r _func_name __aiter___agen)r funcrkwdsr r r r sz&_AsyncGeneratorContextManager.__init__csNtjdkr|jIdH|_z|jdIdHWStyHtddYn0dS)N)zasync generator didn't yield)sys version_inforasendStopAsyncIteration RuntimeErrorr r r r rs   z(_AsyncGeneratorContextManager.__aenter__c st|j4IdH|durhz|jdIdHWn&tyZYWdIdHdS0tdn4|dustJz$|j|||IdHtdWnty}z(||uWYd}~WdIdHSd}~0tyd}zt||urWYd}~WdIdHdSt|ttfrN|j|urNWYd}~WdIdHdSWYd}~n@d}~0t d|urYWdIdHdSYn0WdIdHq1IdHs0YdS)NFzasync generator didn't stopz*async generator didn't stop after athrow()r) rrr r!r"athrow isinstance StopIteration __cause__rexc_info)r typevalue tracebackexcr r r r&s6    0   z'_AsyncGeneratorContextManager.__aexit__cCstdj|jddS)Nz>use 'async with {func_name}(...)', not 'with {func_name}(...)') func_name)r"formatrr r r r __enter__Vs z'_AsyncGeneratorContextManager.__enter__cCsds JddS)NFz#Never called, but should be definedr r r r r __exit__\sz&_AsyncGeneratorContextManager.__exit__N)rrrr rrr.r/r r r r rs 0rcs.tstdtfdd}d|_|S)z Like @contextmanager, but async.z{must be an async generator (native or from async_generator; if using @async_generator then @acontextmanager must be on top.cs t||Sr)r)rrrr r helperhsz#asynccontextmanager..helperT)r TypeErrorrZ__returns_acontextmanager__)rr1r r0r asynccontextmanager`sr3)r functoolsr_implrrrr3r r r r s   G