o NEg@sbddlZddlZddlmZmZzddlmZWney'ddlmZYnwGdddZdS)N)AnyOptional)Dequec@sTeZdZdZdejddfddZddeeddfdd Z de fd d Z dd d Z dS)EventResultOrErrorz This class wrappers the Event asyncio lock allowing either awake the locked Tasks without any error or raising an exception. thanks to @vorpalsmith for the simple design. loopreturnNcCs$||_d|_t|_t|_dSN)_loop_excasyncioEvent_event collectionsdeque_waiters)selfrrg/var/www/eduai.edurigo.com/doc_train/edurigo_ai/Puru/venv/lib/python3.10/site-packages/aiohttp/locks.py__init__s zEventResultOrError.__init__exccCs||_|jdSr)r r set)rrrrrrszEventResultOrError.setc s^|j|j}|j|z |IdH}W|j|n|j|w|jdur-|j|Sr)r create_taskr waitrappendremover )rwaitervalrrrrs   zEventResultOrError.waitcCs|jD]}|qdS)z Cancel all waiters N)rcancel)rrrrrr*s  zEventResultOrError.cancelr)rN) __name__ __module__ __qualname____doc__r AbstractEventLooprr BaseExceptionrrrrrrrrr s  r) r rtypingrrr ImportErrortyping_extensionsrrrrrs