ó _y]c@sÑdZddlZddlmZddlmZddlmZddlZddl m Z ddl m Z m Z de d ee fiƒfd „ƒYZd e d ee fiƒfd „ƒYZdgZdS( s; Based on https://github.com/jupyter/notebook/blob/master/notebook/static/services/kernels/comm.js https://github.com/ipython/ipykernel/blob/master/ipykernel/comm/manager.py https://github.com/ipython/ipykernel/blob/master/ipykernel/comm/comm.py Which are distributed under the terms of the Modified BSD License. iÿÿÿÿN(tLoggingConfigurable(t import_item(t string_types(tQtCore(tMetaQObjectHasTraitst SuperQObjectt CommManagertNewBasecBs¤eZdZd„Zd„Zejeƒd„ƒZd d d d d„Z d„Z d„Z d„Z ejeƒd„ƒZd „Zd „Zd „Zd „ZRS(s+ Manager for Comms in the Frontend cOsEtt|ƒj||Ži|_i|_|rA|j|ƒndS(N(tsuperRt__init__tcommsttargetstinit_kernel_client(tselft kernel_clienttargstkwargs((s.lib/python2.7/site-packages/qtconsole/comms.pyR s   cCs#||_|jjj|jƒdS(sC connect the kernel, and register message handlers N(Rt iopub_channeltmessage_receivedtconnectt _dispatch(R R((s.lib/python2.7/site-packages/qtconsole/comms.pyR $s cCsC|dd}dddg}||kr?t||ƒ|ƒndS(sDispatch messagestheadertmsg_typet comm_opentcomm_msgt comm_closeN(tgetattr(R tmsgRthandled_msg_types((s.lib/python2.7/site-packages/qtconsole/comms.pyR+s cCsat||j|ƒ}|j|ƒy|j|||ƒWn!tk r\|j|ƒ‚nX|S(sÉ Create a new Comm, register it, and open its Kernel-side counterpart Mimics the auto-registration in `Comm.__init__` in the Jupyter Comm. argument comm_id is optional (tCommRt register_commtopent Exceptiontunregister_comm(R t target_nametdatatmetadatatcomm_idtbufferstcomm((s.lib/python2.7/site-packages/qtconsole/comms.pytnew_comm3s   cCs/t|tƒrt|ƒ}n||j|R?(R RR:R%R'((s.lib/python2.7/site-packages/qtconsole/comms.pyR•s     cCsu|d}|d}|j|ƒ}|dkr3dSy|j|ƒWn*tk rp|jjd|dtƒnXdS(sHandler for comm_msg messagesR:R%NsException in comm_msg for %sR;(R9R=t handle_msgR R1R>R?(R RR:R%R'((s.lib/python2.7/site-packages/qtconsole/comms.pyR¥s    N(t__name__t __module__t__doc__R R RtSlottobjectRR=R(R+R-RR!R9RRR(((s.lib/python2.7/site-packages/qtconsole/comms.pyRs        RcBs’eZdZejeƒZd d d d„Zd„Z d d d d„Z d d d d„Z d d d d„Z d„Z d„Zd„Zd „ZRS( s Comm base class cCswtt|ƒjd|ƒ||_||_|dkrItjƒj}n||_ ||_ ||_ |jj |_ dS(s; Create a new comm. Must call open to use. R"N(RRR R"RR=tuuidtuuid1thexR%t _msg_callbackt_close_callbackt shell_channelt _send_channel(R R"RR%t msg_callbacktclose_callback((s.lib/python2.7/site-packages/qtconsole/comms.pyR ºs      cCs‚|dkri}n|dkr*i}n|j|d<||d<|jjj||d|ƒ}|rr||d s  "›"Z