sj 8ddlZddlZddlmZdZdZdddZy)N)checkURIcfd}|S)z0 Decorator for RPC procedure endpoints. ct|sJt|dsg|_|jjdt i|S)N _wslinkurisuri)callablehasattrrappendr)frs 8/DATA/.local/lib/python3.12/site-packages/wslink/core.pydecoratezregister..decorate s@{{q-(AM eXc]34)rrs` r registerrs  Orc tj}|j |t j|g|i|S#t$r,tj}tj|Y]wxYw)a  Schedule callback (which is passed args and kwargs) to be called on running event loop after delay seconds (can be floating point). Returns asyncio.TimerHandle on which cancel() can be called to cancel the eventual invocation of the callback. )asyncioget_event_loop RuntimeErrornew_event_loopset_event_loop call_later functoolspartial)delaycallbackargskwargsloops r schedule_callbackr !sj%%%' ??5)"3"3H"Nt"Nv"N OO %%%'t$%s?2A43A4) done_callbackc, tj}t j |g|i||j|fdS|j|fdS#t$r,tj}tj|YzwxYw)a Creates a coroutine out of the provided coroutine function coro_func and the provided args and kwargs, then schedules the coroutine to be called on the running event loop after delay seconds (delay can be float or int). Returns asyncio.Task on which cancel() can be called to cancel the running of the coroutine. The coro_func parameter should not be a coroutine, but rather a coroutine function (a function defined with async). The reason for this is we want to defer creation of the actual coroutine until we're ready to schedule it with "ensure_future". Otherwise every time we cancel a TimerTask returned by "call_later", python prints "RuntimeWarning: coroutine '' was never awaited". cVtjjSN)r ensure_futureadd_done_callback) coro_partialr!sr z$schedule_coroutine..Ns G)),.9KKrc8tjSr$)rr%)r'sr r(z$schedule_coroutine..Rs'*?*? *Or)rrrrrrrr)r coro_funcr!rrrr's ` @r schedule_coroutiner+4s"%%%'$$Y@@@L     ??5"O PP %%%'t$%sA2BB)rrrrrr r+rrr r,s% 4P&?CQr