^^[TT]5 UTlUTlUTl[ 5mSUU4SjjnTRceTRR U5 TRSS9 g)zCreate a channel. Parameters ---------- socket : :class:`zmq.Socket` The ZMQ socket to use. session : :class:`session.Session` The session to use. loop A tornado ioloop to connect the socket to using a ZMQStream NcB>TRce[R"TRTR5TlTRR TR 5 TRS5 g![anTRU5 SnAgSnAff=fN) rr ZMQStreamioloopstreamon_recv _handle_recv set_result Exception set_exceptionefselfs jC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\jupyter_client/threaded.py setup_stream7ThreadedZMQSocketChannel.__init__..setup_stream<s{ #{{...'11$++t{{K  ##D$5$56 T" #"" #sA$A99 BBB timeoutrN)super__init__rrrr add_callbackresult)r(rrrr*r' __class__s` @r)r1!ThreadedZMQSocketChannel.__init__$sh"    H # #{{&&&   . FcUR$)zWhether the channel is alive. _is_aliver(s r)is_alive!ThreadedZMQSocketChannel.is_aliveMs ~~r6cSUlg)zStart the channel.TNr8r:s r)startThreadedZMQSocketChannel.startQs r6cSUlg)zStop the channel.FNr8r:s r)stopThreadedZMQSocketChannel.stopUs r6c^^TRbKTRb>[5mS UU4SjjnTRRU5 TR SS9 TRb"TRRS S 9 STl gg![ a;n[ 5nSTRSU3nURU[SS9 SnANpSnAff=f![ a N]f=f) zClose the channel.Nc>TRb TRRSS9 STlTRS5 g![anTR U5 SnAgSnAff=f)Nrlinger)rcloser"r#r$r%s r) close_stream4ThreadedZMQSocketChannel.close..close_stream_s]'{{. )))3&* LL&!'OOA&&'s-A A' A""A'r-zError closing stream z: ) stacklevelrrEr/) rrrr2r3r#r warningRuntimeWarningrrG)r(rHr&logmsgr's` @r)rGThreadedZMQSocketChannel.closeYs ;; "t{{'>A ' ' KK $ $\ 2 ?# ;; "  !!!+DK #  ? l-dkk]"QC@ CA > ?  s* B )C C1C  C C C rPcn^^SUU4SjjnTRceTRRU5 g)zQueue a message to be sent from the IOLoop's thread. Parameters ---------- msg : message to send This is threadsafe, as it uses IOLoop.add_callback to give the loop's thread control of the action. Ncp>TRceTRRTRT5 gr)rsendr)rPr(sr) thread_send2ThreadedZMQSocketChannel.send..thread_sends+<<+ ++ LL  dkk3 /r6r/)rr2)r(rPrUs`` r)rTThreadedZMQSocketChannel.sendys1 0 0{{&&&   -r6msg_listcURceURceURRU5up#URRU5nUR(aUR U5 UR U5 g)zKCallback for stream.on_recv. Unpacks message, and calls handlers with it. N)rrfeed_identities deserialize_inspect call_handlers)r(rXidentsmsgrPs r)r!%ThreadedZMQSocketChannel._handle_recvso {{&&&||'''ll228< ll&&t, == MM#  3r6cg)aAThis method is called in the ioloop thread when a message arrives. Subclasses should override this method to handle incoming messages. It is important to remember that this method is called in the thread so that some logic must be done to ensure that the application level handlers are called in the application thread. Nr(rPs r)r]&ThreadedZMQSocketChannel.call_handlerss r6cg)zQSubclasses should override this with a method processing any pending GUI events. Nrbr:s r)process_events'ThreadedZMQSocketChannel.process_eventss r6r.c0^[R"5U-nTRceTRbTRR 5(a Sn[ U5eS[ SS4U4Sjjn[S5Hn[5nTRR[XF55 [U[R"5- S5nUR[U[R"5- S55 M g![a  gf=f)aImmediately processes all pending messages on this channel. This is only used for the IOPub channel. Callers should use this method to ensure that :meth:`call_handlers` has been called for all messages that have been received on the 0MQ SUB socket of this channel. This method is thread safe. Parameters ---------- timeout : float, optional The maximum amount of time to spend flushing, in seconds. The default is one second. NzAttempt to flush closed streamr'rc>TR5 URS5 g![anURU5 SnAgSnAff=fr)_flushr"r#r$)r'r&r(s r)flush-ThreadedZMQSocketChannel.flush..flushs@ #  T" #"" #s% A AA rKr)time monotonicrrclosedOSErrorrrangerr2rmaxr3 TimeoutError)r(r. stop_time_msgrk_r's` r)rkThreadedZMQSocketChannel.flushs&NN$w. {{&&& ;; $++"4"4"6"63D$-  #S #T #qAA KK $ $WU%6 7)dnn&66:G Y)991=>    s1D DDcdURceURR5 SUlg)z"Callback for :method:`self.flush`.NT)rrk_flushedr:s r)rjThreadedZMQSocketChannel._flushs){{&&&  r6)ryr9rrrrr/)g?)#__name__ __module__ __qualname____firstlineno____doc__rrrrr\r zmqSocketrr r1r9boolr;r>rArGrstrrrTrr!r]rffloatrkrj__static_attributes__ __classcell__r4s@r)rrs8G F F FH%$%'"%v %  %NI$@.S#X.4.$  T  d   c3h D  +U+T+Zr6rc^\rSrSrSrSrSrSU4Sjjr\\ RSSj55r SSjr SSjr SS jrSS jrSS jrSS jrS rU=r$) IOLoopThreadz;Run a pyzmq ioloop in a thread to send and receive messagesFNc0>[TU]5 SUlg)zInitialize an io loop thread.TN)r0r1daemonr(r4s r)r1IOLoopThread.__init__s  r6c*[b S[lgg)NT)r_exitingrbr6r) _notice_exitIOLoopThread._notice_exits  #$(L ! $r6c[5Ul[R"U5 URR SS9 g)zcStart the IOLoop thread Don't return until self.ioloop is defined, which is created in the thread r,r-N)r _start_futurerr>r3r:s r)r>IOLoopThread.starts1 &,X T !!"!-r6cr^[R"5n[R"U5 SU4SjjnURU"55 TRR S5 WRTR55 g![ a%nTRRU5 SnANJSnAff=f)z0Run my loop, ignoring EINTR events in the pollerNcB># [R"5Tlg7fr)r currentrr:sr) assign_ioloop'IOLoopThread.run..assign_ioloops$nn. sr/) asyncionew_event_loopset_event_looprun_until_completerr"r#r$ _async_run)r(rrr&s` r)runIOLoopThread.runs 0))+D  " "4 ( /  # #MO 4    ) )$ /  12  0    , ,Q / / 0sA B B6B11B6c# UR(d2[R"S5IShvN UR(dM1ggN7f)z(Run forever (until self._exiting is set)rN)rrsleepr:s r)rIOLoopThread._async_run s,----" " "--- "s+A AA A c`SUlUR5 UR5 SUlg)zStop the channel's event loop and join its thread. This calls :meth:`~threading.Thread.join` and returns when the thread terminates. :class:`RuntimeError` will be raised if :meth:`~threading.Thread.start` is called again. TN)rjoinrGrr:s r)rAIOLoopThread.stops$    r6c$UR5 gr)rGr:s r)__del__IOLoopThread.__del__s  r6ctURbURRSS9 gg![a gf=f)zClose the io loop thread.NT)all_fds)rrGr#r:s r)rGIOLoopThread.close s? ;; "  !!$!/ #  s * 77)rrrrr/)r{r|r}r~rrrr1 staticmethodatexitregisterrr>rrrArrGrrrs@r)rrsXEH F  __)) .3"# r6rc ^\rSrSrSr\S\\4Sj5r\ "\ SS9r SS\ S\ S \ S \ S \ SS 4 U4S jjjr S\\\4SS 4SjrSU4Sjjr\"\5r\"\5r\"\5r\"\5r\"\5rS\ 4SjrSrU=r$)ThreadedKernelClienti)zYA KernelClient that provides thread-safe sockets with async callbacks on message replies.rcRUR(aURR$gr) ioloop_threadrr:s r)rThreadedKernelClient.ioloop,s   %%,, ,r6T) allow_noneshelliopubstdinhbcontrolNc>[5UlURR5 U(aURURl[ TU]XX4U5 g)z!Start the channels on the client.N)rrr>_check_kernel_info_reply shell_channelr\r0start_channels)r(rrrrrr4s r)r#ThreadedKernelClient.start_channels4sI*^   " *.*G*GD   ' uU@r6rPc\USS:Xa#URU5 SURlgg)zGThis is run in the ioloop thread when the kernel info reply is receivedmsg_typekernel_info_replyN)_handle_kernel_info_replyrr\rcs r)r-ThreadedKernelClient._check_kernel_info_replyEs0 z?1 1  * *3 /*.D   ' 2r6c>[TU]5 UR(a;URR5(aURR 5 ggg)z Stop the channels on the client.N)r0 stop_channelsrr;rArs r)r"ThreadedKernelClient.stop_channelsKsF    $"4"4"="="?"?    # # %#@ r6cRURbURR5$g)z$Is the kernel process still running?T) _hb_channel is_beatingr:s r)r;ThreadedKernelClient.is_aliveWs*    '##..0 0r6)r)TTTTTr/)r{r|r}r~rpropertyr r rr rrrrrrrrrr riopub_channel_classshell_channel_classstdin_channel_classrhb_channel_classcontrol_channel_classr;rrrs@r)rr)sc ( \d;M AAA A  A  A AA"/DcN/t/ & 787878I !9:$r6r)"rrrrmconcurrent.futuresr functoolsr threadingrtypingrrrr rtornado.ioloopr traitletsr r traitlets.logr zmq.eventlooprchannelsrclientrrrrrrrbr6r)rsd %,, !$$# DI6IX6<6r6