o º¼tf³ã@sŠdZddlmZddlmZmZddlmZddlm Z ddl m Z ddl m Z Gd d „d e eƒZGd d „d ee ƒZGd d„de eƒZdS)z9 Defines a KernelClient that provides signals and slots. é)Ú HBChannel)ÚThreadedKernelClientÚThreadedZMQSocketChannel)ÚQtCore)ÚTypeé)ÚQtKernelClientMixin)Ú SuperQObjectc@s"eZdZdZe e¡Zdd„ZdS)Ú QtHBChannelg@cCó|j |¡dS)zD Reimplemented to emit signals instead of making callbacks. N)Ú kernel_diedÚemit)ÚselfZsince_last_heartbeat©rúY/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/qtconsole/client.pyÚ call_handlersszQtHBChannel.call_handlersN) Ú__name__Ú __module__Ú __qualname__Z time_to_deadrÚSignalÚobjectr rrrrrr s  r c@s2eZdZdZe e¡Zdd„Zdd„Z dd„Z dS) ÚQtZMQSocketChannelz=A ZMQ socket emitting a Qt signal when a message is received.cCstj ¡ ¡dS)z) Process any pending GUI events. N)rZQCoreApplicationÚinstanceZ processEvents©rrrrÚprocess_events!sz!QtZMQSocketChannel.process_eventscCr )aThis 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Úmsgrrrr&sz QtZMQSocketChannel.call_handlerscCs|jdup |j ¡S)zCheck if the channel is closed.N)ÚstreamÚclosedrrrrr0szQtZMQSocketChannel.closedN) rrrÚ__doc__rrrrrrrrrrrrs   rc@s0eZdZdZeeƒZeeƒZeeƒZee ƒZ dS)ÚQtKernelClientz5 A KernelClient that provides signals and slots. N) rrrrrrZiopub_channel_classZshell_channel_classZstdin_channel_classr Zhb_channel_classrrrrr 5s  r N)rZjupyter_client.channelsrZjupyter_client.threadedrrZqtpyrZ traitletsrZ kernel_mixinsrÚutilr r rr rrrrÚs