o кZhzу@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 ·B/var/www/html/lang_env/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)rZget_running_loopr r!r"r#Zget_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..cr3rr r4r6r rr8Аr9N)┌ _get_selectorr1┌ add_readerr/Z add_writer)r+r%┌socketZevtr7┌selectorr r6r┌_watch_raw_socketzs zPoller._watch_raw_socketcGs*t|Г}|D]}|а|б|а|бqdS)z$Unschedule callback for a raw socketN)r:┌ remove_readerZ remove_writer)r+r%Zsocketsr=r<r r r┌_unwatch_raw_socketsВs ■zPoller._unwatch_raw_socketsN)r r rrr>r@r r r rr2wsr2c@s0eZdZdZeZd ddДZd ddДZddДZdS) ┌Socketz.N)r:r;┌_fdrBr 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_loopZ is_closedrCr:r?)r+r%r r r┌_clear_io_stateЪs zSocket._clear_io_stater) r r rrr2Z _poller_classr:rDrFr r r rrAКs rAc@seZdZdZeZdZdS)┌Contextz/Context for creating asyncio-compatible SocketsN)r r rrrA┌ _socket_classZ _instancer r r rrGзsrGcs"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 rrL╢szZMQEventLoop.__init__r)r r rrrL┌ __classcell__r r rMrrI░srIcCs$tjrdSdt_tjdtddНdS)NTzsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.щr)rJ┌calledr!r"┌DeprecationWarningr r r rrJ╛s ¤rJFcCs tГdS)z(DEPRECATED: No longer needed in pyzmq 17N)rJr r r r┌install═s rS)rGrAr2rIrS)rr)#r┌ __future__rrr-┌sysr!rr┌weakrefrZzmqZ_zmqrr┌__annotations__r#rr$r&┌platformr:r(Z_AsyncPollerr2Z_AsyncSocketrArHrGrI┌_looprJrQrS┌__all__r r r r┌s8 <