o "4g| @s>UdZddlmZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z ejZded<d Zded <e d Ze rKejZded <ejZded <nGdddeZGdd d ejedZGdd d ejedZGdddeeZGdddeeZ  d/d0dd Z  d/d1d#d$Zdd%d2d+d,Zdd%d3d-d.ZdS)4z Utilities to ease the differences between async and sync code. These object offer a similar interface between sync and async versions; the script async_to_sync.py will replace the async names with the sync names when generating the sync version. ) annotationsN)AnyCallable Coroutine TYPE_CHECKING) TypeAliasTypeVarrWorkerasyncio.Task[None]AWorkerT_GQueue_AGQueuec@seZdZddZdS)FakeGenericMetacCs|S)N)selfitemrrY/var/www/html/authentication-server/venv/lib/python3.10/site-packages/psycopg/_acompat.py __getitem__!szFakeGenericMeta.__getitem__N)__name__ __module__ __qualname__rrrrrr s rc@ eZdZdS)rNrrrrrrrr$) metaclassc@r)rNrrrrrr'rcs$eZdZdZd d fd d ZZS)Queuez> A Queue subclass with an interruptible get() method. TNblockbooltimeout float | Nonereturnr cs|durd}tj||dS)Ng@)rr )superget)rrr  __class__rrr$0sz Queue.get)TN)rrr r!r"r )rrr__doc__r$ __classcell__rrr%rr+src@r)AQueueNrrrrrr)7rr)rf(Callable[..., Coroutine[Any, Any, None]]argstuple[Any, ...]name str | Noner"cCstj|||dS)z, Equivalent to asyncio.create_task. )r.)asyncio create_task)r*r,r.rrraspawn;sr2Callable[..., Any]threading.ThreadcCstj|||dd}||S)z= Equivalent to creating and running a daemon thread. T)targetr,r.daemon) threadingThreadstart)r*r,r.trrrspawnFsr;r tasksasyncio.Task[Any]r r!Nonecs\tj|}z|durtjt||dIdHWdS|IdHWdStjy-YdSw)7 Equivalent to asyncio.gather or Thread.join() Nr<)r0gatherwait_forshield TimeoutError)r r=waitrrragatherSs  rFcGs"|D] }|s q||qdS)r@N)is_alivejoin)r r=r:rrrrAcs  rA)rN)r*r+r,r-r.r/r"r )r*r3r,r-r.r/r"r4)r=r>r r!r"r?)r=r4r r!r"r?)r' __future__rqueuer0r7typingrrrr_compatrr r8r __annotations__r r rrrtyperr)r2r;rFrArrrrs4