o ¹iم@s0UdZddlZddlZddlZddlZddlmZmZddlmZddl Z ddl mZeƒZee d<Gdd„deƒZd ejfd d„Zd ejfdd „ZejdkrReZneZGdd„dƒZGdd„deejƒZGdd„deejƒZee_Gdd„de jeƒZGdd„deƒZdZdd„Zde_dd„Z gd¢Z!dS)z8AsyncIO support for zmq Requires asyncio and Python 3. éN)عFutureعSelectorEventLoop)عWeakKeyDictionary)ع_futureع _selectorsc@seZdZdZdS)عProactorSelectorThreadWarningz•Warning class for notifying about the extra thread spawned by tornado We automatically support proactor via tornado's AddThreadSelectorEventLoopN)ع__name__ع __module__ع__qualname__ع__doc__©rrْF/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/zmq/asyncio.pyrsrعreturncs’ˆtvrtˆSttdƒrGtˆtjƒrGzddlm}Wnty&tdƒ‚wt j dtddچ|ˆƒ‰tˆ<ˆj‰‡‡‡fdd „}|ˆ_ˆSˆS) zّGet selector-compatible loop Returns an object with ``add_reader`` family of methods, either the loop itself or a SelectorThread instance. Workaround Windows proactor removal of *reader methods, which we need for zmq sockets. عProactorEventLoopr)عAddThreadSelectorEventLoopaProactor event loop does not implement add_reader family of methods required for zmq. zmq will work with proactor if tornado >= 6.1 can be found. Use `asyncio.set_event_loop_policy(WindowsSelectorEventLoopPolicy())` or install 'tornado>=6.1' to avoid this error.aProactor event loop does not implement add_reader family of methods required for zmq. Registering an additional selector thread for add_reader support via tornado. Use `asyncio.set_event_loop_policy(WindowsSelectorEventLoopPolicy())` to avoid this warning.é©ع stacklevelcsˆˆ_t ˆd،ˆ ،dS©N)عcloserعpopr©عasyncio_loopع loop_closeع selector_looprr ع_close_selector_and_loopIsz7_get_selector_windows.._close_selector_and_loop) rعhasattrعasyncioع isinstancerعtornado.platform.asynciorعImportErrorعRuntimeErrorعwarningsعwarnعRuntimeWarningr)rrrrrr ع_get_selector_windowss.ےےےù r%cCs|S)zno-op on non-Windowsr)عlooprrr ع_get_selector_noopVsr'عwin32c@s$eZdZeZejZejZ dd„Z dS)ع_AsyncIOcCsFtjdkrzt ،WStytjdtddچYt ،Swt ،S)N)ééuONo running eventآ loop. zmq.asyncio should be used from within an asyncio loop.ér) عsysعversion_inforعget_running_loopr!r"r#r$عget_event_loop©عselfrrr ع _default_loopfs ‎ùz_AsyncIO._default_loopN)rr r rع_Futureع selectorsعEVENT_WRITEع_WRITEع EVENT_READع_READr3rrrr r)as r)c@s eZdZdZdd„Zdd„ZdS)عPollerz1Poller returning asyncio.Future for poll results.csLt|ƒ}||j@r| |‡fdd„،||j@r$| |‡fdd„،dSdS)z"Schedule callback for a raw socketcَˆƒSrr©عargs©عfrr ع{َz*Poller._watch_raw_socket..cr;rrr<r>rr r@}rAN)ع _get_selectorr9ع add_readerr7ع add_writer)r2r&عsocketعevtr?عselectorrr>r ع_watch_raw_socketws ےzPoller._watch_raw_socketcGs*t|ƒ}|D]}| |،| |،qdS)z$Unschedule callback for a raw socketN)rBع remove_readerع remove_writer)r2r&عsocketsrGrErrr ع_unwatch_raw_socketss ‏zPoller._unwatch_raw_socketsN)rr r rrHrLrrrr r:tsr:c@s0eZdZdZeZd dd„Zd dd„Zdd„ZdS) عSocketz.N)rBrCع_fdrOrr1r ع_init_io_state‘s ےzSocket._init_io_statecCs>|j}|r| ،s|jdkr| |، |j،dSdSdSdS)zEclear any ioloop event handler called once at close éےےےےN)ع _current_loopع is_closedrRrBrI)r2r&rrr ع_clear_io_state—sےzSocket._clear_io_stater) rr r rr:ع _poller_classrBrSrWrrrr rM‡s rMc@seZdZdZeZdZdS)عContextz/Context for creating asyncio-compatible SocketsN)rr r rrMع _socket_classع _instancerrrr rY¤srYcs"eZdZdZd‡fdd„ Z‡ZS)عZMQEventLoopz}DEPRECATED: AsyncIO eventloop using zmq_poll. pyzmq sockets should work with any asyncio event loop as of pyzmq 17. Ncstƒtƒ |،Sr)ع_deprecatedعsuperع__init__)r2rG©ع __class__rr r_³szZMQEventLoop.__init__r)rr r rr_ع __classcell__rrr`r r\sr\cCs$tjrdSdt_tjdtddچdS)NTzsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.r*r)r]عcalledr"r#عDeprecationWarningrrrr r]»s ‎r]FcCs tƒdS)z(DEPRECATED: No longer needed in pyzmq 17N)r]rrrr عinstallتs re)rYrMr:r\re)"rrr5r-r"rrعweakrefrعzmqع_zmqrrع__annotations__r$rعAbstractEventLoopr%r'عplatformrBr)ع_AsyncPollerr:ع_AsyncSocketrMrZrYr\ع_loopr]rcreع__all__rrrr عs: ‏9