
    
8d                         d Z ddlmZ ddlmZmZ ddlmZ ddlm	Z	 ddl
mZ ddlmZ  G d	 d
ee          Z G d dee          Z G d dee          ZdS )z9 Defines a KernelClient that provides signals and slots.
    )	HBChannel)ThreadedKernelClientThreadedZMQSocketChannel)QtCore)Type   )QtKernelClientMixin)SuperQObjectc                   8    e Zd ZdZ ej        e          Zd ZdS )QtHBChannelg      @c                 :    | j                             |           dS )zD Reimplemented to emit signals instead of making callbacks.
        N)kernel_diedemit)selfsince_last_heartbeats     0lib/python3.11/site-packages/qtconsole/client.pycall_handlerszQtHBChannel.call_handlers   s"     	233333    N)	__name__
__module____qualname__time_to_deadr   Signalobjectr   r    r   r   r   r      s;        L  &-''K4 4 4 4 4r   r   c                   D    e Zd ZdZ ej        e          Zd Zd Z	d Z
dS )QtZMQSocketChannelz=A ZMQ socket emitting a Qt signal when a message is received.c                 f    t           j                                                                         dS )z) Process any pending GUI events.
        N)r   QCoreApplicationinstanceprocessEventsr   s    r   process_eventsz!QtZMQSocketChannel.process_events!   s+     	((**88:::::r   c                 :    | j                             |           dS )a  This method is called in the ioloop thread when a message arrives.

        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.
        N)message_receivedr   )r   msgs     r   r   z QtZMQSocketChannel.call_handlers&   s!     	""3'''''r   c                 F    | j         du p| j                                         S )zCheck if the channel is closed.N)streamclosedr"   s    r   r)   zQtZMQSocketChannel.closed0   s"    {d":dk&8&8&:&::r   N)r   r   r   __doc__r   r   r   r%   r#   r   r)   r   r   r   r   r      sY        GG$v}V,,; ; ;
( ( (; ; ; ; ;r   r   c                   j    e Zd ZdZ ee          Z ee          Z ee          Z ee	          Z
dS )QtKernelClientz5 A KernelClient that provides signals and slots.
    N)r   r   r   r*   r   r   iopub_channel_classshell_channel_classstdin_channel_classr   hb_channel_classr   r   r   r,   r,   5   s]         $122$122$122tK((r   r,   N)r*   jupyter_client.channelsr   jupyter_client.threadedr   r   qtpyr   	traitletsr   kernel_mixinsr	   utilr
   r   r   r,   r   r   r   <module>r7      s    . - - - - - R R R R R R R R             / . . . . .      4 4 4 4 4,	 4 4 4; ; ; ; ;1< ; ; ;0) ) ) ) )(*> ) ) ) ) )r   