B in¦dpã@s6ddlZddlZddlmZmZmZGdd„dƒZdS)éN)ÚAnyÚDequeÚOptionalc@sTeZdZdZejddœdd„Zdeeddœdd„Z e d œd d „Z dd œd d „Z dS)ÚEventResultOrErrorzÓEvent asyncio lock helper class. Wraps the Event asyncio lock allowing either to awake the locked Tasks without any error or raising an exception. thanks to @vorpalsmith for the simple design. N)ÚloopÚreturncCs$||_d|_t ¡|_t ¡|_dS)N)Ú_loopÚ_excÚasyncioÚEventÚ_eventÚ collectionsÚdequeÚ_waiters)Úselfr©rú1/tmp/pip-unpacked-wheel-fdo6ttx3/aiohttp/locks.pyÚ__init__s zEventResultOrError.__init__)ÚexcrcCs||_|j ¡dS)N)r r Úset)rrrrrrszEventResultOrError.set)rc ÃsP|j |j ¡¡}|j |¡z|IdH}Wd|j |¡X|jdk rL|j‚|S)N)rZ create_taskr ÚwaitrÚappendÚremover )rÚwaiterÚvalrrrrs  zEventResultOrError.waitcCsx|jD] }| ¡qWdS)zCancel all waitersN)rÚcancel)rrrrrr&s zEventResultOrError.cancel)N) Ú__name__Ú __module__Ú __qualname__Ú__doc__r ZAbstractEventLooprrÚ BaseExceptionrrrrrrrrrs  r)r r ÚtypingrrrrrrrrÚs