fp<ddlZddlZddlmZmZmZGddZy)N)AnyDequeOptionalc`eZdZdZdej ddfdZd deeddfdZ de fdZ d d Z y) 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. loopreturnNc||_d|_tj|_t j |_yN)_loop_excasyncioEvent_event collectionsdeque_waiters)selfrs L/opt/lhia/ganansol/python/venv/lib/python3.12/site-packages/aiohttp/locks.py__init__zEventResultOrError.__init__s- -1 mmo 4?4E4E4G exccF||_|jjyr )r rset)rrs rrzEventResultOrError.sets  rcjK|jj|jj}|jj | |d{}|jj ||j |j|S79#|jj |wxYwwr )r create_taskrwaitrappendremover )rwaitervals rrzEventResultOrError.waits'' (8(8(:; V$ ),C MM  ( 99 ))O  MM  (s0AB3BBB5B3BB00B3cF|jD]}|jy)zCancel all waitersN)rcancel)rr s rr#zEventResultOrError.cancel&smm F MMO rr )r N) __name__ __module__ __qualname____doc__rAbstractEventLooprr BaseExceptionrrrr#rrrrsLHW66H4H x .$ C rr)rrtypingrrrrr*rrr,s''##r