h)SrSSKJr SSKrSSKrSSKrSSKrSSKr\R(aSSK J r \R"S5r \R\\R 4r\R$\R\\R 4r\R$\R(\r\R.\/S4r\R.S\/S4r"SS5r"SS 5rSS /rg) z?Default classes for Comm and CommManager, for usage in IPython.) annotationsN) ZMQStreamCommBaseCommc6^\rSrSrSrSSU4SjjjrSSSjjrSSjrSSSjjrSSSjjr SSSjjr SS jr SS jr SS jr SS jrS rU=r$)rzClass for communicating between a Frontend and a Kernel Must be subclassed with a publish_msg method implementation which sends comm messages through the iopub channel. c  >[T U]"S0U D6 U(aUO[R"5RUlX`lXlXplU(aUOSUR 3RS5Ul U (aU O0Ul U (aU O0Ul SUl SUlSUlUR (aUR!X#US9 gSUlg)Nzcomm-asciiTdatametadatabuffersF)super__init__uuiduuid4hexcomm_idprimary target_name target_moduleencodetopic _open_data _close_data _msg_callback_close_callback_closedopen) selfrr r rrrrrrrkwargs __class__s aC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\comm/base_comm.pyrBaseComm.__init__!s "6"")wtzz|/?/?  &*#UE$,,*@)H)H)Q (2**5;22648 << II4GI D DLc Sn[U5e)Nz*publish_msg Comm method is not implemented)NotImplementedError)r!msg_typer r rkeysmsgs r$ publish_msgBaseComm.publish_msgEs;!#&&r&c[R"[5 URSS9 SSS5 g!,(df  g=f)ztrigger close on gcT)deletingN) contextlibsuppress Exceptioncloser!s r$__del__BaseComm.__del__Ps,   + JJJ %, + +s 4 Ac .Uc URn[R"5nUc Sn[U5eUR U5 UR SUUUUR URS9 SUlg![a URU5 ef=f)z+Open the frontend-side version of this commNz.Comms cannot be opened without a comm_manager. comm_open)r r rrrF) rcommget_comm_manager RuntimeError register_commr,rrrr2unregister_comm)r!r r r comm_managerr+s r$r BaseComm.openYs <??D,,.  BCs# #""4(    ! ,,"00  !DL   ( ( .  s /A77BcUR(agSUlUc URnURSUUUS9 U(d%[R"5R U5 gg)z,Close the frontend-side version of this commNT comm_closer )rrr,r9r:r=)r!r r rr/s r$r3BaseComm.closetse <<  <##D      ! ! # 3 3D 9r&c(URSUUUS9 g)z8Send a message to the frontend-side version of this commcomm_msgr N)r,)r!r r rs r$send BaseComm.sends#    r&cXlg)zRegister a callback for comm_close Will be called with the `data` of the close message. Call `on_close(None)` to disable an existing callback. N)rr!callbacks r$on_closeBaseComm.on_closes  (r&cXlg)zRegister a callback for comm_msg Will be called with the `data` of any comm_msg messages. Call `on_msg(None)` to disable an existing callback. N)rrHs r$on_msgBaseComm.on_msgs &r&c[RSURU5 UR(aURU5 gg)zHandle a comm_close messagezhandle_close[%s](%s)N)loggerdebugrr)r!r+s r$ handle_closeBaseComm.handle_closes3 +T\\3?      % r&c0[RSURU5 UR(adSSKJn U"5nU(aUR RS5 URU5 U(aUR RS5 ggg)zHandle a comm_msg messagezhandle_msg[%s](%s)r) get_ipython pre_execute post_executeN)rPrQrrIPythonrUeventstrigger)r!r+rUshells r$ handle_msgBaseComm.handle_msgsl )4<<=    +ME $$]3   s # $$^4 r&) rrrrrrrrrr) r9NNNNTNNNN)rstrr MaybeDictr r_r BuffersTyper str | Nonerboolrrarz bytes | Nonerr_rr_r"t.AnyreturnNone)NNN) r)r^r r_r r_rr`r*rcrdrerdre)r r_r r_rr`rdre)NNNF) r r_r r_rr`r/rbrdre)rIzCommCallback | Nonerdre)r+ MessageTyperdre)__name__ __module__ __qualname____firstlineno____doc__rr,r5r r3rErJrMrRr\__static_attributes__ __classcell__)r#s@r$rrs""#"$(" $!%"!"!"! "!  "!  "!"!""!"!"!"!"! "!"!N"# ' ' ' '  '  '  '&Z^09KV :"# ::: :  :  :2Z^    09  KV    (&& 5 5r&cr\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr S rg ) CommManagerzDDefault CommManager singleton implementation for Comms in the Kernelc 0Ul0Ulg)Ncommstargetsr4s r$rCommManager.__init__s*, 68 r&cX[U[5(aJURSS5n[U5S:XaUupE[ XE/S9n[ Xe5nO[ US5n[R"[U5URU'g![ anSU3n[U5UeSnAff=f)zRegister a callable f for a given target name f will be called with two arguments when a comm_open message is received with `target`: - the Comm instance - the `comm_open` message itself. f can be a Python callable or an import string for one. .)fromlistzNo module named Nr) isinstancer^rsplitlen __import__getattrAttributeError ImportErrortcastCommTargetCallbackru) r!rfpartspackageobjmodulee error_msgs r$register_targetCommManager.register_targets a  HHS!$E5zQ$ #Ge<8,A uQx($%FF+=q$A [!&8"23% 8I%i0a78s B B)B$$B)c8URRU5$)z5Unregister a callable registered with register_target)rupop)r!rrs r$unregister_targetCommManager.unregister_targets|| ,,r&c:URnXRU'U$)zRegister a new comm)rrt)r!r9rs r$r<CommManager.register_comms,," 7r&cNURRUR5ng)z,Unregister a comm, and close its counterpartN)rtrr)r!r9s r$r=CommManager.unregister_commszz~~dll+r&c,URU$![ax [RSU5 [R [ R 5(a7[RS[URR555 gf=f)zGet a comm with a particular id Returns the comm if found, otherwise None. This will not raise an error, it will log messages if the comm cannot be found. zNo such comm: %szCurrent comms: %sN) rtKeyErrorrPwarning isEnabledForloggingDEBUGrQlistr*)r!rs r$get_commCommManager.get_commsk ::g& &  NN-w 7""7==11 0$tzz7H2IJ  sA?BBcSSKJn USnUSnUSnURRUS5nU"USUS9n UR U 5 Uc[ R S U5 O U"X5 gU R"5 g![a [ R S US S 9 N4f=f![a [ R S S S 9 gf=f)zHandler for comm_open messagesr) create_commcontentrrNF)rrrz"No such comm target registered: %sz&Exception opening comm with target: %sTexc_infozqCould not close comm during `comm_open` failure clean-up. The comm may not have been opened yet.) r9rrugetr<rPerrorr2r3) r!streamidentr+rrrrrr9s r$r8CommManager.comm_opens$i.)$m, LL  [$ /#  4 9 LL={ K c$    JJL  c E{]a b c   LLE   s$&B0B'B$#B$'CCcUSnUSnURU5nUcgUR"U5 g![a [R SUSS9 gf=f)zHandler for comm_msg messagesrrNzException in comm_msg for %sTr)rr\r2rPrr!rrr+rrr9s r$rDCommManager.comm_msg(sai.)$}}W% <  Q OOC  Q LL74L P Qs4AAcUSnUSnURU5nUcgSURUlURU UR"U5 g![a [ R SUSS9 gf=f)zHandler for comm_close messagesrrNTzException in comm_close for %sr)rrtrrRr2rPrrs r$rACommManager.comm_close5si.)$}}W% < &* 7# JJw  S   c " S LL97TL R SsAA76A7rsNrf)rr^rzCommTargetCallback | strrdre)rr^rrrdr)r9rrdr^)r9rrdre)rr^rdzBaseComm | None)rrrr^r+rgrdre)rhrirjrkrlrrrr<r=rr8rDrArmrr&r$rprps6N9B6- , &B QSr&rp)rl __future__rr0rtypingrrr9 TYPE_CHECKINGzmq.eventloop.zmqstreamr getLoggerrPDictr^AnyrgOptionalr_Listbytesr`Callable CommCallbackrrrp__all__rr&r$rsE# ??1   6 "ffS!%%Z JJqvvc155j) * jj' zz;--. ZZ[ 94 ?@d5d5NBSBSJ } %r&