ha2SrSSKJr SSKrSSKJr SSKJr SSKJ r SSK J r SSK J r JrJrJrJrJr SSKrSS KJrJrJr "S S \5r"S S 5r"SS\\R45r"SS5r\"SSS9r"SS\\R<\5rg)z%Future-returning APIs for coroutines.) annotationsN)Future)deque)partial)chain)Any AwaitableCallable NamedTupleTypeVarcast)EVENTSPOLLINPOLLOUTcR\rSrSr%S\S'S\S'S\S'S\S 'S \S 'S \S 'S rg) _FutureEventrfuturestrkindtupleargsdictkwargsrmsgtimerN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r^C:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\zmq/_future.pyrrs N I K L H Jr$rcT\rSrSr%SrSrS\S'S\S'S SjrS S jrS SS jjr S r g)_Async+zMixin for common async logicNr _current_loopz type[Future]_FuturecURc<UR5UlURUR5 UR$UR5nXRLaXlURU5 U$)zoGet event loop Notice if event loop has changed, and register init_io_state on activation of a new event loop )r) _default_loop_init_io_state)self current_loops r% _get_loop_Async._get_loop1su    %!%!3!3!5D     2 2 3%% %))+ 11 1!-     -r$c[S5e)Nz!Must be implemented in a subclassNotImplementedError)r.s r%r,_Async._default_loopBs!"EFFr$cgNrr.loops r%r-_Async._init_io_stateEs r$)r))returnrr7)r;None) rrr r!__doc__r)r"r0r,r-r#rr$r%r'r'+s*&M3 "G  r$r'cr^\rSrSr%SrS\S'S\S'S\S'S\S 'SS jrSS jrSSU4S jjjrS r U=r $) _AsyncPollerIz:Poller that returns a Future on poll, instead of blocking.ztype[_AsyncSocket] _socket_classint_READ_WRITEz list[Any] raw_socketsc[5e)z"Schedule callback for a raw socketr3)r.r9socketevtfs r%_watch_raw_socket_AsyncPoller._watch_raw_socketQ !##r$c[5e)z$Unschedule callback for a raw socketr3)r.r9socketss r%_unwatch_raw_sockets!_AsyncPoller._unwatch_raw_socketsUrLr$c>^^ ^^^^^TR5m US:Xa#[TT] S5nT RU5 T $TR 5mTR5m/mU4SjnTRUUU4Sj5 /mU4SjnTRGH4upg[U[R5(a[UTR5(d,TRRU5nTRU5 U[R-(aUR!STS9 U[R"-(aUR%STS9 MMTRU5 SnU[R-(aUTR&-nU[R"-(aUTR(-nTR+TXhU5 GM7 UU UU4Sjn TRU 5 T(aTRU5 Ub9US:a3U4S jn TR-S U-U 5mUU4S jn T RU 5 U4S jn T RU 5 T $![anT R U5 SnAT $SnAff=f) z Return a Future for a poll eventrNcT>TR5(dTRS5 ggr7done set_result)rwatchers r%wake_raw#_AsyncPoller.poll..wake_rawms!<<>>""4("r$c*>TR"T/TQ76$r7)rO)rIr9rEr.s r%#_AsyncPoller.poll..rsd//C{Cr$c8>THnUR5 M gr7)_clear_io_state)rIswrapped_socketss r%_clear_wrapper_io,_AsyncPoller.poll.._clear_wrapper_iows$!!#%r$pollrc>TR5(agTR5(aTR5 gTR 5(a TR TR 55 g[ [T]#S5nTRU5 g![a gf=f![anTR U5 SnAgSnAff=fNr) rT cancelledcancel RuntimeError exception set_exceptionsuperr?rbrU Exception)rIresulte __class__rr.rVs r% on_poll_ready(_AsyncPoller.poll..on_poll_readys{{}}  ""MMO  ""$$W%6%6%89."<;A>F%%f-$!,((++,s)B5B* B'&B'* C4C  CcT>TR5(dTRS5 ggr7rS)rVsr%trigger_timeout*_AsyncPoller.poll..trigger_timeouts!||~~&&t,&r$MbP?cl>[TS5(aTR5 gTRT5 g)Nrg)hasattrrgremove_timeout)rIr9timeout_handles r%cancel_timeout)_AsyncPoller.poll..cancel_timeouts*>844"))+''7r$cR>TR5(dTR5 ggr7)rTrg)rIrVs r%cancel_watcher)_AsyncPoller.poll..cancel_watchers<<>> "r$)r*rkrbrUrlrjr0add_done_callbackrN isinstance_zmqSocketrA from_socketappendr_add_recv_eventr_add_send_eventrCrDrJ call_later)r.timeoutrmrnrWr`rGmaskrHrprsrzr}rr9rEryrVr_ros` @@@@@@r%rb_AsyncPoller.pollYs% a< *a!!&)M~~,,."$  ) !! C /1 $!LLLF&$++..!&$*<*<==!//;;FCF#**62$++%**6'*B$,,&**6'*B'""6*$++%4::%C$,,&4;;&C&&tV(C#)& . .( !!-0   % %&7 8  7Q; -"__TG^_MN 8  $ $^ 4 !   0 } ($$Q''M  (sI I;I66I;r) r9rrGrrHrBrIr r;r<)r9rrNrr;r<))r;z Awaitable[list[tuple[Any, int]]]) rrr r!r=r"rJrOrbr# __classcell__ros@r%r?r?Is2D%% J K$$ddr$r?c$\rSrSr\S5rSrg)_NoTimercgr7rrr$r%rg_NoTimer.cancels r$rN)rrr r! staticmethodrgr#rr$r%rrs  r$rT _AsyncSocket)boundc^\rSrSr%SrSrSrS\S'\r Sr S"S#U4Sjjjr \ S$S%Sjj5r S$S&U4Sjjjr\R RR"\lU4S jr\R R$R"\lS'S(S jjrS'S)S jjrSSS .S*S jjrS'S+SjjrS'S,SjjrSrS\R24S-SjjrSrSr\S$Sj5rSSSS.S.SjjrS/Sjr Sr!Sr"S0Sjr#S$Sjr$Sr%Sr&Sr'S$Sjr(S r)S!r*U=r+$)1rNr _zmq.Socket _shadow_sockc >[U[R5(aSUpAUb[TU]UR S9 X@lO?[TU]"X40UD6 [RRUR 5UlUb1[R"URRS3[SS9 [5Ul[5UlSUlUR R"Ulg)N)shadowz^(io_loop) argument is deprecated in pyzmq 22.2. The currently active loop will always be used.) stacklevelr)rrrrk__init__ underlyingrrwarningswarnrorDeprecationWarningr _recv_futures _send_futures_stateFD_fd)r.context socket_typeio_loop _from_socketrros r%r_AsyncSocket.__init__s gt{{ + +%)7\  # G L$;$;  < ,  G W >**+,BB"   #W"W $$''r$cU"XS9$)z.Create an async socket from an existing Socket)rrr)clsrGrs r%r_AsyncSocket.from_sockets88r$c>UR(dURb[[UR=(d /UR =(d /55nUH?nUR R5(aM$UR R5 MA UR5 [TU]1US9 g![a Mnf=f)N)linger) closedrlistrrrrrTrgrhr]rkclose)r.r event_listeventros r%r_AsyncSocket.closes{{txx3-1d((.B0B0B0HbI.J$||((** ++-$  "  V $ (sB>> C  C c\>[TU]U5nU[:XaURU5 U$r7)rkgetr_schedule_remaining_events)r.keyrmros r%r_AsyncSocket.gets+S! &=  + +F 3 r$c 2URS[XUS9S9$)zfReceive a complete multipart zmq message. Returns a Future whose result will be a multipart message. recv_multipartflagscopytrackrrrr.rrrs r%r_AsyncSocket.recv_multiparts(## T%N$  r$c 2URS[XUS9S9$)zReceive a single zmq frame. Returns a Future, whose result will be the received frame. Recommend using recv_multipart instead. recvrrrrs r%r_AsyncSocket.recvs(## 4eeD$  r$nbytesrc 4URSU4[X#S9S9$)z~Receive a single zmq frame into a pre-allocated buffer. Returns a Future, whose result will be the number of bytes received. recv_intor)rrr)r.bufrrs r%r_AsyncSocket.recv_into&s*## sfT-M$  r$c :X%S'X5S'XES'URSXS9$)zaSend a complete multipart zmq message. Returns a Future that resolves when sending is complete. rrrsend_multipartrr)r)r. msg_partsrrrrs r%r_AsyncSocket.send_multipart1s0 wvw##$4)#SSr$c lX%S'X5S'XES'UR[X#US95 URSXS9$)z|Send a single zmq frame. Returns a Future that resolves when sending is complete. Recommend using send_multipart instead. rrrrsendr)updaterr)r.datarrrrs r%r_AsyncSocket.send=sB wvw d?@##F#DDr$c^^^UR5mUUU4SjnTRU5 UU4SjnTRU5 T$)zDeserialize with Futuresc>TR5(aITR5(d3TR5c"[R"STSTS3[ 5 gTR5(a TR TR55 gTR5nT"U5nTRU5 g![anTR U5 SnAgSnAff=f)z+Chain result through serialization to recvdNzFuture z completed while awaiting z. A message has been dropped!) rTrfrirrRuntimeWarningrjrmrUrl)_rloadedrnrIloadrecvds r%_chain)_AsyncSocket._deserialize.._chainUsvvxx((U__->-FMM"!$>ugEbc&     12lln)!#YFLL(!'OOA&&'s&C C% C  C%c~>TR5(agTR5(aTR5 gg)z"Chain cancellation from f to recvdN)rTrfrg)rrIrs r% _chain_cancel0_AsyncSocket._deserialize.._chain_cancelps*zz||{{}} r$)r*r)r.rrrrrIs `` @r% _deserialize_AsyncSocket._deserializeQs= LLN )2 '  M*r$c^^^TR(a$[R"[R5eTR 5nUR TU5 [ [URU55mTR5mUUU4SjnTR5(a U"T5 OTRU5 U4SjnTRU5 T$)zCpoll the socket for events returns a Future for the poll results. c~>TR5(agTR5(aTR5 gUR 5(a TR TR 55 g[ TR55nTRURTS55 g![a gf=fre) rTrfrgrhrirjrrmrUr)rIevtsr poll_futurer.s r% unwrap_result(_AsyncSocket.poll..unwrap_results{{}}$$&&MMO{{}}$$[%:%:%<=K..01!!$((4"34$sB// B<;B<ct>TR5(dTR5 gg![a gf=f)z4Cancel underlying poll if request has been cancelledN)rTrgrh)rrs r% cancel_poll&_AsyncSocket.poll..cancel_polls<##%%&&(&$s * 77) rrZMQErrorENOTSUP _poller_classregisterr rrbr*rTr)r.rrprrrrs` @@r%rb_AsyncSocket.poll{s ;;-- - -     46166'?3  5      + &  ) )- 8    - r$c2^U4SjnURX#5$)z'Add a timeout for a send or recv Futurecz>TR5(agTR[R"55 gr7)rTrjrAgainrcsr%future_timeout1_AsyncSocket._add_timeout..future_timeouts'{{}}   .r$) _call_later)r.rrrs ` r% _add_timeout_AsyncSocket._add_timeouts /88r$c@UR5RX5$)zSchedule a function to be called later Override for different IOLoop implementations Tornado and asyncio happen to both have ioloop.call_later with the same signature. )r0r)r.delaycallbacks r%r_AsyncSocket._call_laters~~**5;;r$cXU(dgURU5 g![a gf=f)zMake sure that futures are removed from the event list when they resolve Avoids delaying cleanup until the next send/recv event, which may never come. N)remove ValueError)rrrs r%_remove_finished_future$_AsyncSocket._remove_finished_futures/     e $   s  )))rrrc U=(d UR5nUcSnUc0nURS5(aZURSS5[R-(a2[ UR U5nU"U0UD6nURU5 U$[n [[S5(a0UR Rn U S:aURXZS-5n [XQX#SU S9n URR!U 5 UR R["5[$-(aUR'5 UR(aRXR;aCUR)[+UR,URU S 95 UR/[$5 U$![anURU5 SnAU$SnAff=f) z4Add a recv event, returning the corresponding FutureNrrrrRCVTIMEOrurrrrrr)r* startswithrrDONTWAITgetattrrrUrlrjrrwrcvtimeorrrrrr _handle_recvrrr _add_io_state) r.rrrrrIrrrnr timeout_ms _future_events r%r_AsyncSocket._add_recv_events  $dlln <D >F ??6 " "vzz'1'= 'M4,,d3D $)&) QH 4 $ $**33JQ))!$->?% $4u  !!-0     (6 1       -3E3E"E   00#11'    v &E #""H  #s9F&& G 0GG c U=(d UR5nUS;aUR(dURSS5nUR5nU[R -US'[ URU5nSn U"U40UD6n URU 5 U (a#UR(aUR5 U$[n [[S5(aCURR[R 5n U S:aUR#X]S-5n [%XQS X2U S 9nURR'U5 UR)[+UR,URUS 95 UR/[05 U$![Ra<n U[R -(aURU 5 Sn A GN7Sn Sn A GN?Sn A f[an URU 5 Sn A GNcSn A ff=f) z4Add a send event, returning the corresponding Future)rrrrTFNSNDTIMEOrurr r )r*rrrrrrrrUrrjrlrrrrwrrrrrrrrr)r.rrrrrIr nowait_kwargsr finish_earlyrrnrrrs r%r_AsyncSocket._add_send_event s  $dlln - -d6H6HJJw*E"KKMM%*T]]%:M' "4,,d3D L . . Q%%335 4 $ $**..t}}=JQ))!$->?% "VE  !!-0  ,,--#   7#S:: )4==(OOA&&$)L #"" #s* FH$)GG H(G??Hc@URR[5[-(dgSnUR(aJURR 5upp4pVUR 5(aSnOOUR(aMJUR(dUR[5 UcgWR5 WS:XaURS5 gUS:XaURRnOIUS:XaURRnO,US:XaURRnO[SU<35eWS==[R-ss'U"W0UD6nURU5 g![ an UR#U 5 Sn A gSn A ff=f)zHandle recv eventsNrbrrrzUnhandled recv event type: r)rrrrrpopleftrT_drop_io_statergrUrrrrrrrlrj) r.rIrrrrrrrmrns r%r_AsyncSocket._handle_recvJs[  $$V,v5    .2.@.@.H.H.J +AT1vvxx    !!    ' 9   6> LL   % %$$33D V^$$))D [ $$..D:4(CD Dw4==( !4*6*F LL   OOA   sE88 FFFcURR[5[-(dgSnUR(aJURR 5upp4pVUR 5(aSnOOUR(aMJUR(dUR[5 UcgWR5 WS:XaURS5 gUS:XaURRnO,US:XaURRnO[SU<35eWS==[R-ss'U"W40UD6nURU5 g![an UR!U 5 Sn A gSn A ff=f)NrbrrzUnhandled send event type: r)rrrrrrrTrrgrUrrrrrrlrj) r.rIrrrrrrrmrns r% _handle_send_AsyncSocket._handle_sendusB  $$V,w6    040B0B0J0J0L -AT3vvxx    !!    ( 9   6> LL   % %$$33D V^$$))D:4(CD Dw4==( !#((F LL   OOA   s E F&E<<Fc:URR(agURR[5nU[R -(aUR 5 U[R-(aUR5 UR5 g)z(Dispatch IO events to _handle_recv, etc.N) rrrrrrrrr!r)r.fdevents zmq_eventss r%_handle_events_AsyncSocket._handle_eventssf    # # &&**62  #      $     '')r$cURS:XagUcURR[5nXR-(aUR SUR 5 gg)z[Schedule a call to handle_events next loop iteration If there are still events to handle. rN)rrrrrr')r.r%s r%r'_AsyncSocket._schedule_remaining_eventssS ;;!   >&&**62F KK    Q 3 3 4 r$cURU:waURU-=olURUR5 g)zAdd io_state to poller.Nr_update_handlerr.states r%r_AsyncSocket._add_io_states3 ;;% "&++"5 5EK T[[)r$cURU-(aURU)-UlURUR5 g)z&Stop poller from watching an io_state.Nr,r.s r%r_AsyncSocket._drop_io_states2 ;; ++%0DK T[[)r$cRU(aUR5 UR5 g)z?Update IOLoop handler with state. zmq FD is always read-only. N)r0rr.s r%r-_AsyncSocket._update_handlers  NN  '')r$cUcUR5nURURURUR5 UR SUR5 g)z#initialize the ioloop event handlerNr)r0 add_handlerrr'rCrr8s r%r-_AsyncSocket._init_io_statesK <>>#D **D,?,?L D//0r$cURnURR(a URnURbURR U5 gg)z>unregister the ioloop event handler called once during close N)rrrr)remove_handler)r.r$s r%r]_AsyncSocket._clear_io_statesL       # #B    )    - -b 1 *r$)rrrrr)NrNN)rz_zmq.Socket | Noner;r<r7)rztype[T]rGrrrr;r)rz int | Noner;r<)rTF)rrBrboolrr;r;z)Awaitable[list[bytes] | list[_zmq.Frame]])rrBrr;rr;r;zAwaitable[bytes | _zmq.Frame])rrBrrBr;Awaitable[int])rrrrBrr;r;%Awaitable[_zmq.MessageTracker | None]) rrrrBrr;rr;rrr;r=)r;r<) rrrz tuple | Nonerzdict[str, Any] | Nonerz Future | Noner;r)NNN)rr),rrr r!rrrr"r?rrr classmethodrrrrr=rrrrrrrrrbrrrrrrrr!r'rrrr-r-r]r#rrs@r%rrsQMM F M C+/ ( ) ( ((:99 % %KK%%--EM ++//))CK@E    $(  8<  2  @E    $(  8<  &  ()q  !$  14    HM T T%( T48 T . T EEE E  E  E /E((T t{{0d 9<*"(, $ 55 5 & 5  5 5n;z)!V&!R *5 * * *1 2 2r$) r= __future__rrasyncior collectionsr functoolsr itertoolsrtypingrr r r r r zmqrrrrrr'Pollerr?rrrrrr$r%rGs+#'':$