o #`^hp@s6ddlZddlZddlmZmZmZGdddZdS)N)AnyDequeOptionalc@sTeZdZdZdejddfddZddeeddfdd Z de fd d Z dd d Z dS)EventResultOrErrorzEvent 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. loopreturnNcCs$||_d|_t|_t|_dSN)_loop_excasyncioEvent_event collectionsdeque_waiters)selfrrK/home/air/shanriGPT/back/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)zCancel all waitersN)rcancel)rrrrrr&s  zEventResultOrError.cancelr)rN) __name__ __module__ __qualname____doc__r AbstractEventLooprr BaseExceptionrrrrrrrrrs  r)r rtypingrrrrrrrrs