i| UdZddlmZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z ejZded<d Zded <e d Zer#ej&Zded <ej&Zded <n9GddeZGdd ej&eZGdd ej&eZGddeeZGddeeZ d ddZ d ddZddddZddd dZy)!z 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) TYPE_CHECKINGAnyCallable Coroutine) TypeAliasTypeVarr Workerasyncio.Task[None]AWorkerT_GQueue_AGQueueceZdZdZy)FakeGenericMetac|S)N)selfitems p/var/www/html/hwPaymentPortal-be-dev/hw-payment-portal-api/venv/lib/python3.12/site-packages/psycopg/_acompat.py __getitem__zFakeGenericMeta.__getitem__!sKN)__name__ __module__ __qualname__rrrrrr s rrc eZdZy)rNrrrrrrrr$ r) metaclassc eZdZy)rNrrrrrr'rrc&eZdZdZddfd ZxZS)Queuez> A Queue subclass with an interruptible get() method. c.|d}t|||S)Ng@)blocktimeout)superget)rr%r& __class__s rr(z Queue.get0s ?(Gw{{88r)TN)r%boolr& float | Nonereturnr)rrr__doc__r( __classcell__)r)s@rr#r#+s99rr#c eZdZy)AQueueNrrrrr0r07srr0c6tj|||S)z, Equivalent to asyncio.create_task. )name)asyncio create_task)fargsr2s raspawnr7;s   q$xd 33rcXtj|||d}|j|S)z= Equivalent to creating and running a daemon thread. T)targetr6r2daemon) threadingThreadstart)r5r6r2ts rspawnr?Fs( 4EAGGI Hrr&cKtj|} |3tjtj||d{y|d{ y77#tj$rYywxYww)7 Equivalent to asyncio.gather or Thread.join() Nr@)r3gatherwait_forshield TimeoutError)r&taskswaits ragatherrISst >>5 !D  ""7>>$#7I I I  JJ  J       sXA4/AAA A4 AAAA4AAA1.A40A11A4cV|D]$}|js|j|&y)rBN)is_alivejoin)r&rGr>s rrCrCcs*zz|  wr)rN)r5z(Callable[..., Coroutine[Any, Any, None]]r6tuple[Any, ...]r2 str | Noner,r )r5zCallable[..., Any]r6rMr2rNr,threading.Thread)rGzasyncio.Task[Any]r&r+r,None)rGrOr&r+r,rP)r- __future__rqueuer3r;typingrrrr_compatr r r<r __annotations__r rr#rrtyperr0r7r?rIrCrrrrWs.# ::'$$ $)) CLGY$!--Hi'$ %++  7==O  9GAJ 9 Xa[ 4/4 4 4 4           FJ  >Br