B b ,cم@s6UdZddlZddlZddlZddlZddlmZmZddlmZddl Z ddl mZeƒZee d<Gdd„deƒZejd œd d„Zejd œdd „Zejdkr¤eZneZGdd„dƒZGdd„deejƒZGdd„deejƒZee_Gdd„de jeƒZGdd„deƒZdZdd„Zde_dd„Z dddddgZ!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ْ*lib/python3.7/site-packages/zmq/asyncio.pyrsr)عreturncsœˆtkrtˆSttdƒr”tˆtjƒr”yddlm}Wntk rRtdƒ‚YnXt j dtddچ|ˆƒ‰tˆ<ˆj‰‡‡‡fdd „}|ˆ_ˆSˆSd 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_loopN) rعhasattrعasyncioع isinstancerZtornado.platform.asynciorعImportErrorعRuntimeErrorعwarningsعwarnعRuntimeWarningr)rrrr)rrrr ع_get_selector_windowss& r!cCs|S)zno-op on non-Windowsr)عlooprrr ع_get_selector_noopVsr#Zwin32c@s$eZdZeZejZejZ dd„Z dS)ع_AsyncIOcCs@tjdkr8yt ،Stk r6tjdtddچYnXt ،S)N)ééuONo running eventآ loop. zmq.asyncio should be used from within an asyncio loop.é)r) عsysعversion_inforZget_running_looprrrr Zget_event_loop)عselfrrr ع _default_loopfs z_AsyncIO._default_loopN)rr r rZ_Futureع selectorsZEVENT_WRITEع_WRITEZ EVENT_READع_READr+rrrr r$asr$c@s eZdZdZdd„Zdd„ZdS)عPollerz1Poller returning asyncio.Future for poll results.csHt|ƒ}||j@r&| |‡fdd„،||j@rD| |‡fdd„،dS)z"Schedule callback for a raw socketcsˆƒS)Nr)عargs)عfrr ع{َz*Poller._watch_raw_socket..csˆƒS)Nr)r0)r1rr r2}r3N)ع _get_selectorr.ع add_readerr-Z add_writer)r*r"عsocketZevtr1عselectorr)r1r ع_watch_raw_socketws zPoller._watch_raw_socketcGs.t|ƒ}x |D]}| |،| |،qWdS)z$Unschedule callback for a raw socketN)r4ع remove_readerZ remove_writer)r*r"Zsocketsr7r6rrr ع_unwatch_raw_socketss zPoller._unwatch_raw_socketsN)rr r rr8r:rrrr r/tsr/c@s0eZdZdZeZd dd„Zd dd„Zdd„ZdS)عSocketz.N)r4r5ع_fd)r*r<r)r*r ع_init_io_state‘s zSocket._init_io_statecCs2|j}|r.| ،s.|jdkr.| |، |j،dS)zEclear any ioloop event handler called once at close éےےےےN)Z _current_loopZ is_closedr=r4r9)r*r"rrr ع_clear_io_state—szSocket._clear_io_state)N)N) rr r rr/Z _poller_classr4r>r@rrrr r;‡s r;c@seZdZdZeZdZdS)عContextz/Context for creating asyncio-compatible SocketsN)rr r rr;ع _socket_classZ _instancerrrr rA¤srAcs"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ƒ |،S)N)ع_deprecatedعsuperع__init__)r*r7)ع __class__rr rF³szZMQEventLoop.__init__)N)rr r rrFع __classcell__rr)rGr rCsrCcCs$tjr dSdt_tjdtddچdS)NTzsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.r%)r)rDعcalledrrعDeprecationWarningrrrr rD»srDFcCs tƒdS)z(DEPRECATED: No longer needed in pyzmq 17N)rDrrrr عinstallتsrK)"rrr,r(rrrعweakrefrZzmqZ_zmqrrع__annotations__r rZAbstractEventLoopr!r#عplatformr4r$Z_AsyncPollerr/Z_AsyncSocketr;rBrArCZ_looprDrIrKع__all__rrrr عs<7