o ¹¼tfzم@s0UdZddlmZddlZddlZddlZddlZddlmZmZddl m Z ddlZddlm Z e ƒZded<Gd d „d eƒZd"d d„Zd"dd„ZejdkrReZneZGdd„dƒZGdd„dee jƒZGdd„dee jƒZee_Gdd„dejeƒZGdd„deƒZdZdd„Zde_ dd „Z!gd!¢Z"dS)#z8AsyncIO support for zmq Requires asyncio and Python 3. é)عannotationsN)عFutureعSelectorEventLoop)عWeakKeyDictionary)ع_futurerع _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__©r r ْT/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/zmq/asyncio.pyrsrعreturnْasyncio.AbstractEventLoopcs’ˆ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_loopZ loop_closeZ selector_loopr rع_close_selector_and_loopMsz7_get_selector_windows.._close_selector_and_loop) rعhasattrعasyncioع isinstancerZtornado.platform.asynciorعImportErrorعRuntimeErrorعwarningsعwarnعRuntimeWarningr)rrrr rrع_get_selector_windowss4‏ےےù ےr$cCs|S)zno-op on non-Windowsr )عloopr r rع_get_selector_noopZsr&عwin32c@s$eZdZeZejZejZ dd„Z dS)ع_AsyncIOcCs4zt ،WStytjdtddچYt ،Sw)NuONo running eventآ loop. zmq.asyncio should be used from within an asyncio loop.ér)rعget_running_loopr r!r"r#عget_event_loop©عselfr r rع _default_loopjs ‎ùz_AsyncIO._default_loopN)r r rrZ_Futureع selectorsعEVENT_WRITEع_WRITEع EVENT_READع_READr.r r r rr(es 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©عfr rع~َz*Poller._watch_raw_socket..cr5rr r6r8r rr:€r;N)ع _get_selectorr3ع add_readerr1ع add_writer)r-r%عsocketZevtr9عselectorr r8rع_watch_raw_socketzs ےzPoller._watch_raw_socketcGs*t|ƒ}|D]}| |،| |،qdS)z$Unschedule callback for a raw socketN)r<ع remove_readerع remove_writer)r-r%عsocketsr@r?r r rع_unwatch_raw_sockets‚s ‏zPoller._unwatch_raw_socketsN)r r rrrArEr r r rr4wsr4c@s0eZdZdZeZd dd„Zd dd„Zdd„ZdS) عSocketz.N)r<r=ع_fdrHr r,rع_init_io_state”s ےzSocket._init_io_statecCs>|j}|r| ،s|jdkr| |، |j،dSdSdSdS)zEclear any ioloop event handler called once at close éےےےےN)Z _current_loopع is_closedrIr<rB)r-r%r r rع_clear_io_stateڑsےzSocket._clear_io_stater) r r rrr4Z _poller_classr<rJrMr r r rrFٹs rFc@seZdZdZeZdZdS)عContextz/Context for creating asyncio-compatible SocketsN)r r rrrFع _socket_classZ _instancer r r rrN§srNcs"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__)r-r@©ع __class__r rrS¶szZMQEventLoop.__init__r)r r rrrSع __classcell__r r rTrrP°srPcCs$tjrdSdt_tjdtddچdS)NTzsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.ér)rQعcalledr!r"عDeprecationWarningr r r rrQ¾s ‎rQFcCs tƒdS)z(DEPRECATED: No longer needed in pyzmq 17N)rQr r r rعinstallحs rZ)rNrFr4rPrZ)rr)#rع __future__rrr/عsysr!rrعweakrefrZzmqZ_zmqrrع__annotations__r#rr$r&عplatformr<r(Z_AsyncPollerr4Z_AsyncSocketrFrOrNrPع_looprQrXrZع__all__r r r rعs8 <