:vj UddlmZddlmZmZddlmZddlmZm Z erFddl m Z ddlm Z m Z mZmZddlZddlZddlmZe d Zd ed <ed ee d ffZd ed<GddeZdaded<d!dZd"dZe d#dZe d$dZe d%dZd&d'dZGddeZGddeZGddeZ Gd deZ!y)() annotations)ABCabstractmethod)inf) TYPE_CHECKINGoverload) Coroutine)AnyLiteralProtocol TypeAliasN) WeakCallback)asyncioanyiotrior SupportedBackendr. QueueItemceZdZddZddZy) EventLikecy)z5Return ``True`` if the flag is set, ``False`` if not.Nselfs _/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/psygnal/_async.pyis_setzEventLike.is_sets c Kyw)zWait until the flag is set.Nrrs rwaitzEventLike.waits N)returnbool)r zCoroutine | bool | None)__name__ __module__ __qualname__rrrrrrrs   rr_AsyncBackend | None_ASYNC_BACKENDctS)zAGet the current async backend. Returns None if no backend is set.)r&rrrget_async_backendr( s rcDttttrtjdaytttrtjdayttt r.t tdrtjjday)z@Clear the current async backend. Primarily for testing purposes.N _send_channel)r& isinstanceAsyncioBackendclose AnyioBackend TrioBackendhasattrr*rrrclear_async_backendr1%ss! nn 5  "N 5  " N  4~7,,224Nrr,cyNrbackends rset_async_backendr67sFIrr.cyr3rr4s rr6r69sBErr/cyr3rr4s rr6r6;s@Cr _AsyncBackendctr/tj|k7rtdtj|dk(rtatS|dk(rt atS|dk(rt atStd|d)zSet the async backend to use. Must be one of: 'asyncio', 'anyio', 'trio'. This should be done as early as possible, and *must* be called before calling `SignalInstance.connect` with a coroutine function. zAsync backend already set to: rrrzAsync backend not supported: z-. Must be one of: 'asyncio', 'anyio', 'trio')r&_backend RuntimeErrorr,r.r/r4s rr6r6=s.11W<;N># #4 #+   $ s +)+N)r5strr rrDrr Noner rQ) r"r#r$r?propertyrrArErGrMrrrr9r9Xs@ ''//$$rcJeZdZdfd ZeddZddZddZddZxZ S) r,ct|dddl}||_|j |_|j |j|_|j|_ |j|_ y)Nrr) superr?r_asyncioQueue_queue create_taskrG_taskget_running_loop_loopEvent_running)rr __class__s rr?zAsyncioBackend.__init__ms\ # ,3MMO ((4 --/   rc|jSz6Return the event indicating if the backend is running.r_rs rrAzAsyncioBackend.runningw}}rc:|jj|yr3)rY put_nowaitrCs rrEzAsyncioBackend.put|s t$rct|dr6|jjs|jjyyy)z+Close the asyncio backend and cancel tasks.r[N)r0r[donecancelrs rr-zAsyncioBackend.closes1 4 !$**//*; JJ   +< !rcLK|jjry|jj |jj d{} |j |d{=77#t $rddl}|jY$wxYw#|jj$rYn1t$r&}|jjs|Yd}~nd}~wwxYw|jjy#|jjwxYwwNr)r_rsetrYgetrM Exception traceback print_excrWCancelledErrorr<r] is_closedclear)rrDroes rrGzAsyncioBackend.runs ==   !   "![[__..*....... *%'') * }}++   ::'')*  MM   !DMM   !s6D$BA7BA;1A92A;6B9A;;BBBBC'7D9C'C"D"C''D*D$D!!D$rRrOrP) r"r#r$r?rSrArEr-rG __classcell__r`s@rr,r,ls+(% "rc`eZdZUded<ded<d fd Zed dZd dZd dZd d Z xZ S) r.z6anyio.streams.memory.MemoryObjectSendStream[QueueItem] _send_streamz9anyio.streams.memory.MemoryObjectReceiveStream[QueueItem]_receive_streamct|dddl}||_|jt \|_|_|j|_ y)Nrrmax_buffer_size) rVr?r_anyiocreate_memory_object_streamrrxryr^r_)rrr`s rr?zAnyioBackend.__init__sK ! 2S%2S2S3 /4/$  rc|jSrbrcrs rrAzAnyioBackend.runningrdrc:|jj|yr3)rx send_nowaitrCs rrEzAnyioBackend.puts %%d+rct|dr|jjt|dr|jjyy)zClose the anyio streams.rxryN)r0rxr-ryrs rr-zAnyioBackend.closes@ 4 (    # # % 4* +  & & ( ,rcjK|jjry|jj |j4d{|j23d{} |j |d{$747!7 #t $rddl}|jYIwxYw6dddd{7n#1d{7swYnxYw|jj|_|jy#|jj|_|jwxYwwrk) r_rrlryrMrnrorpr}r^r-rrDros rrGzAnyioBackend.runs ==   !   +++"&"6"6.$."nnT222,.2$.(!++- .#7,++++!KK--/DM JJL!KK--/DM JJLs6D3C? A> C? B:B'BB'"B:$B8B9B=B:>C?B'BB$!B:#B$$B:( C?3B64C?:C C C C?0D3?1D00D3rRrOrP) r"r#r$__annotations__r?rSrArEr-rGrurvs@rr.r.s7HHNN&,)rcXeZdZUded<ded<d fd Zed dZd dZd dZxZ S) r/z*trio._channel.MemorySendChannel[QueueItem]r*z"trio.abc.ReceiveChannel[QueueItem]_receive_channelct|dddl}||_|jt \|_|_|jj|_ y)Nrrr{) rVr?r_trioopen_memory_channelrr*rr^r_)rrr`s rr?zTrioBackend.__init__sP   4LD4L4L5 1D1 ((* rc|jSrbrcrs rrAzTrioBackend.runningrdrc:|jj|yr3)r*rrCs rrEzTrioBackend.puts &&t,rcK|jjry|jj |j23d{} |j |d{$77#t $rddl}|jYGwxYw6 |jj|_y#|jj|_wxYwwrk) r_rrlrrMrnrorprr^rs rrGzTrioBackend.runs ==   !   /"33 *d*..... *. *$'') *4!JJ,,.DMDJJ,,.DMsp6C B2B A) B B2A-#A+$A-(B2)B+A--B  B2 B  B2 C2!CCrRrO)rDtupler rQ) r"r#r$rr?rSrArErGrurvs@rr/r/s2==88+-/r)r r%rR)r5zLiteral['asyncio']r r,)r5zLiteral['anyio']r r.)r5zLiteral['trio']r r/)r)r5rr r9)" __future__rabcrrmathrtypingrrcollections.abcr r r r r anyio.streams.memoryrrpsygnal._weak_callbackrrrrrrr&r(r1r6r9r,r.r/rrrrs"#*)883")*D"EiE sCx!@AIyAH(,$+ $ I I E E C C6C(."]."b/=/d%/-%/r