§ ¼قMhvمَ¾—UdZddlmZddlZddlZddlZddlZddlmZmZddl m Z ddlZddlm Z e ¦«Zded<Gd „d e¦«Zdd „Zdd„ZejdkreZneZGd„d¦«ZGd„dee j¦«ZGd„dee j¦«Zee_Gd„deje¦«ZGd„de¦«ZdZd„Zde_ d„Z!gd¢Z"dS)z8AsyncIO support for zmq Requires asyncio and Python 3. é)عannotationsN)عFutureعSelectorEventLoop)عWeakKeyDictionary)ع_futurerع _selectorscَ—eZdZdZdS)عProactorSelectorThreadWarningz•Warning class for notifying about the extra thread spawned by tornado We automatically support proactor via tornado's AddThreadSelectorEventLoopN)ع__name__ع __module__ع__qualname__ع__doc__©َْK/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/zmq/asyncio.pyr r s"€€€€€ًRًRًRًRrr عreturnْasyncio.AbstractEventLoopcَp‡‡‡—‰tvr t‰Sttd¦«r‡t‰tj¦«rm ddlm}n#t$rtd¦«‚wxYwtj dtd¬¦«|‰¦«xٹt‰<‰jٹˆˆˆfd„}|‰_‰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.é©ع stacklevelcَt•—‰‰_t ‰d¦«‰ ¦«dS©N)عcloserعpop)عasyncio_loopع loop_closeع selector_loops€€€rع_close_selector_and_loopz7_get_selector_windows.._close_selector_and_loopMs9ّ€ً",ˆLشفڈNٹNک<¨ر.ش.ذ.ط×زر!ش!ذ!ذ!ذ!r) rعhasattrعasyncioع isinstancerعtornado.platform.asynciorعImportErrorعRuntimeErrorعwarningsعwarnعRuntimeWarningr)rrr!rr s` @@rع_get_selector_windowsr+s(ّّّ€ً•zذ!ذ!فک,ش'ذ'ُچwذ+ر,ش,ً)µطفش!ٌ2ô2ً)ً طKذKذKذKذKذKذKّفً ً ً فًBٌôً ً ُّّّ Œ ً &ُ àً ٌ ô ً ً4Nذ3Mطٌ4 ô4 ً ˆ ‌ <ر0ً "ش'ˆ ً "ً "ً "ً "ً "ً "ً "ً6ˆشطذàذsء AءA+cَ—|S)zno-op on non-Windowsr)عloops rع_get_selector_noopr.Zs€à€Krعwin32cَ4—eZdZeZejZejZ d„Z dS)ع_AsyncIOcَ¨— tj¦«S#t$rtjdt d¬¦«YnwxYwtj¦«S)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©عselfs rع _default_loopz_AsyncIO._default_loopjsn€ً فش+ر-ش-ذ-ّفً ً ً فŒMطaفطً ٌ ô ً ً ً ً ُّّّش%ر'ش'ذ's‚•&>½>N)rrr rع_Futureع selectorsعEVENT_WRITEع_WRITEع EVENT_READع_READr8rrrr1r1es8€€€€€ط€Gط ش "€Fطش €Eً (ً (ً (ً (ً (rr1cَ—eZdZdZd„Zd„ZdS)عPollerz1Poller returning asyncio.Future for poll results.cَ¶‡—t|¦«}||jzr| |ˆfd„¦«||jzr| |ˆfd„¦«dSdS)z"Schedule callback for a raw socketcَ•—‰¦«Srr©عargsعfs €rْz*Poller._watch_raw_socket..~َ ّ€°a°a±c´c€rcَ•—‰¦«SrrrCs €rrFz*Poller._watch_raw_socket..€rGrN)ع _get_selectorr>ع add_readerr<ع add_writer)r7r-عsocketعevtrEعselectors ` rع_watch_raw_socketzPoller._watch_raw_socketzs~ّ€ه ر&ش&ˆطگ”رً ;ط×ز ذ(9ذ(9ذ(9ذ(9ر:ش:ذ:طگ”رً ;ط×ز ذ(9ذ(9ذ(9ذ(9ر:ش:ذ:ذ:ذ:ً ;ً ;rcَ‚—t|¦«}|D],}| |¦«| |¦«Œ-dS)z$Unschedule callback for a raw socketN)rIع remove_readerع remove_writer)r7r-عsocketsrNrLs rع_unwatch_raw_socketszPoller._unwatch_raw_sockets‚sS€ه ر&ش&ˆطً +ً +ˆFط×"ز" 6ر*ش*ذ*ط×"ز" 6ر*ش*ذ*ذ*ً +ً +rN)rrr rrOrTrrrr@r@ws8€€€€€ط;ذ;ً;ً;ً;ً+ً+ً+ً+ً+rr@cَ,—eZdZdZeZdd„Zdd„Zd„ZdS)عSocketz.—sّ€کd×1ز1°!°Qر7ش7€rN)rIrJع_fdrYs` rع_init_io_statezSocket._init_io_state”sDّ€à×زک7ر#ش#×.ز.طŒHذ7ذ7ذ7ذ7ٌ ô ً ً ً rcَ¼—|j}|rN| ¦«s<|jdkr3| |¦« |j¦«dSdSdSdS)zEclear any ioloop event handler called once at close éےےےےN)ع _current_loopع is_closedr^rIrQ)r7r-s rع_clear_io_statezSocket._clear_io_stateڑsq€ً ش!ˆطً =کںڑر(ش(ً =¨T¬X¸ھ^¨^ط×زکtر$ش$×2ز2°4´8ر<ش<ذ<ذ<ذ<ً =ً =ً =ً =¨^¨^rr) rrr rr@ع _poller_classrIr_rdrrrrVrVٹsV€€€€€طFذFà€Mً&ً&ً&ً&ً ً ً ً ً=ً=ً=ً=ً=rrVcَ2‡—eZdZdZeZdZ d dˆfd„ ZˆxZS)عContextz/Context for creating asyncio-compatible SocketsNérr7ع io_threadsْint | _zmq.Contextعshadowْ_zmq.Context | intrعNonecَL•—t¦« ||¦«dSr)عsuperع__init__)r7rirkع __class__s €rrpzContext.__init__°s%ّ€ُ ‰Œ×زک Vر,ش,ذ,ذ,ذ,r)rhr)r7rgrirjrkrlrrm) rrr rrVع _socket_classع _instancerpع __classcell__©rqs@rrgrg§s\ّ€€€€€ط9ذ9à€Mً€Iً *+ط%&ً-ً-ً-ً-ً-ً-ً-ً-ً-ً-ً-rrgcَ$‡—eZdZdZdˆfd„ ZˆxZS)عZMQEventLoopz}DEPRECATED: AsyncIO eventloop using zmq_poll. pyzmq sockets should work with any asyncio event loop as of pyzmq 17. Ncَb•—t¦«t¦« |¦«Sr)ع_deprecatedrorp)r7rNrqs €rrpzZMQEventLoop.__init__¾s$ّ€ف‰ Œ ˆ ف‰wŒw×ز ر)ش)ذ)rr)rrr rrprtrus@rrwrw¸sGّ€€€€€ًًً *ً*ً*ً*ً*ً*ً*ً*ً*ً*rrwcَr—tjrdSdt_tjdtd¬¦«dS)NTzsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.ér)ryعcalledr(r)عDeprecationWarningrrrryryئsF€فشًطˆط…Kشه„Mط}فطًٌôًًًrFcَ"—t¦«dS)z(DEPRECATED: No longer needed in pyzmq 17N)ryrrrعinstallrصs€هپM„M€M€M€Mr)rgrVr@rwr)rr)#rع __future__rr#r:عsysr(rrعweakrefrعzmqع_zmqrrع__annotations__r*r r+r.عplatformrIr1ع_AsyncPollerr@ع_AsyncSocketrVrrrgrwع_loopryr|rع__all__rrrْr‹sYًًًًً#ذ"ذ"ذ"ذ"ذ"à€€€طذذذط € € € ط€€€ط-ذ-ذ-ذ-ذ-ذ-ذ-ذ-ط%ذ%ذ%ذ%ذ%ذ%àذذذطذذذذذً!2ذ 1ر 3ش 3€ ذ3ذ3ذ3ر3ًRًRًRًRًR NٌRôRًRً9ً9ً9ً9ًxًًًً „<گ7زذط)€M€Mà&€Mً(ً(ً(ً(ً(ٌ(ô(ً(ً$+ً+ً+ً+ً+ˆXگwش+ٌ+ô+ً+ً&=ً=ً=ً=ً=ˆXگwش+ٌ=ô=ً=ً4€شً-ً-ً-ً-ً-ˆdŒlک6ش"ٌ-ô-ً-ً"*ً*ً*ً*ً*ذ$ٌ*ô*ً*ً €ً ً ً ً€شًًًً ًً€€€r