ó Û¤[c@sdZddlmZddlmZmZmZddlmZddl m Z ddl m Z m Z de fd „ƒYZejeƒd S( s A client for in-process kernels.iÿÿÿÿ(t DummySocket(tTypetInstancetdefault(tKernelClientABC(t KernelClienti(tInProcessChanneltInProcessHBChanneltInProcessKernelClientcBs1eZdZeeƒZeeƒZeeƒZeeƒZ e dde ƒZ e dƒd„ƒZd„Zd„Zed„ƒZed„ƒZed „ƒZed „ƒZee idd „Zdd „Zdd d„Ze edd„Zed„Zd„Zdd„Zd„Zd„Z d„Z!RS(sA client for an in-process kernel. This class implements the interface of `jupyter_client.clientabc.KernelClientABC` and allows (asynchronous) frontends to be used seamlessly with an in-process kernel. See `jupyter_client.client.KernelClient` for docstrings. s,ipykernel.inprocess.ipkernel.InProcessKernelt allow_nonetblocking_classcCsddlm}|S(Ni(tBlockingInProcessKernelClient(tblockingR (tselfR ((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt_default_blocking_class5scCs&tt|ƒjƒ}|j|d<|S(Ntkernel(tsuperRtget_connection_infoR(R td((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyR:s cOs*tt|ƒjƒ|jjj|ƒdS(N(RRtstart_channelsRt frontendstappend(R targstkwargs((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyR?scCs+|jdkr$|j|ƒ|_n|jS(N(t_shell_channeltNonetshell_channel_class(R ((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt shell_channelCscCs+|jdkr$|j|ƒ|_n|jS(N(t_iopub_channelRtiopub_channel_class(R ((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt iopub_channelIscCs+|jdkr$|j|ƒ|_n|jS(N(t_stdin_channelRtstdin_channel_class(R ((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt stdin_channelOscCs+|jdkr$|j|ƒ|_n|jS(N(t _hb_channelRthb_channel_class(R ((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt hb_channelUsc Csm|dkr|j}ntd|d|d|d|d|ƒ}|jjd|ƒ}|j|ƒ|ddS( Ntcodetsilentt store_historytuser_expressionst allow_stdintexecute_requesttheadertmsg_id(RR)tdicttsessiontmsgt_dispatch_to_kernel(R R%R&R'R(R)tcontentR/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pytexecute^s    cCs^|dkrt|ƒ}ntd|d|ƒ}|jjd|ƒ}|j|ƒ|ddS(NR%t cursor_postcomplete_requestR+R,(RtlenR-R.R/R0(R R%R3R1R/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pytcompleteis   icCsd|dkrt|ƒ}ntd|d|d|ƒ}|jjd|ƒ}|j|ƒ|ddS(NR%R3t detail_leveltinspect_requestR+R,(RR5R-R.R/R0(R R%R3R7R1R/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pytinspectqs   trangecKsLtd|d|d||}|jjd|ƒ}|j|ƒ|ddS(Ntrawtoutputthist_access_typethistory_requestR+R,(R-R.R/R0(R R;R<R=tkwdsR1R/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pythistory{s   cCstdƒ‚dS(Ns!Cannot shutdown in-process kernel(tNotImplementedError(R trestart((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pytshutdown‚scCs+|jjdƒ}|j|ƒ|ddS(sRequest kernel info.tkernel_info_requestR+R,(R.R/R0(R R/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt kernel_info†s cCsR|dkri}ntd|ƒ}|jjd|ƒ}|j|ƒ|ddS(s6Request a dictionary of valid comms and their targets.t target_nametcomm_info_requestR+R,N(RR-R.R/R0(R RFR1R/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt comm_infoŒs    cCs.|jdkrtdƒ‚n||j_dS(Ns*Cannot send input reply. No kernel exists.(RRt RuntimeErrort raw_input_str(R tstring((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pytinput–scCs5|jjdi|d6ƒ}|j|ƒ|ddS(Ntis_complete_requestR%R+R,(R.R/R0(R R%R/((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyt is_complete›s cCsŽ|j}|dkr$tdƒ‚ntƒ}|jj||ƒ|jƒ}|j||ƒ|jj|dt ƒ\}}|j j |ƒdS(s: Send a message to the kernel and handle a reply. s&Cannot send request. No kernel exists.tcopyN( RRRIRR.tsendtrecv_multiparttdispatch_shelltrecvtFalseRtcall_handlers_later(R R/Rtstreamt msg_partstidentst reply_msg((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyR0 s    N("t__name__t __module__t__doc__RRRRR RR#RtTrueRRRRRtpropertyRRR!R$RTRR2R6R9R@RCRERHRLRNR0(((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyRs2               N(R\tipykernel.inprocess.socketRt traitletsRRRtjupyter_client.clientabcRtjupyter_client.clientRtchannelsRRRtregister(((s9lib/python2.7/site-packages/ipykernel/inprocess/client.pyts –