U uõ?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-_pk67_um/aiohttp/locks.pyÚ__init__s zEventResultOrError.__init__)ÚexcrcCs||_|j ¡dSr)r r Úset)rrrrrrszEventResultOrError.set)rc ÃsP|j |j ¡¡}|j |¡z|IdH}W5|j |¡X|jdk rL|j‚|Sr)r Z create_taskr ÚwaitrÚappendÚremover )rÚwaiterÚvalrrrrs  zEventResultOrError.waitcCs|jD] }| ¡qdS)zCancel all waitersN)rÚcancel)rrrrrr&s zEventResultOrError.cancel)N) Ú__name__Ú __module__Ú __qualname__Ú__doc__r ZAbstractEventLooprrÚ BaseExceptionrrrrrrrrrs  r)r rÚtypingrrrrrrrrÚs