Format: application/x-python-code
1 o
2
3 �hi � @ st d Z ddlZddlmZmZ ddlmZ ddlmZ ddl m
4 Z
5 G dd � d e�Z G d
6 d � d e �Z G d d
7 � d
8 e
9 �Z
10 dS )zf Implements a fully blocking kernel client.
11
12 Useful for test suites and blocking terminal interfaces.
13 � N)�Empty�Queue)�Type� )�InProcessChannel)�InProcessKernelClientc sB e Zd ZdZ� fdd�Zdd� Zddd �Zd
14 d � Zd d
15 � Z� Z S )�BlockingInProcessChannelz A blocking in-process channel.c s t � j|i |�� t� | _dS )zInitialize the channel.N)�super�__init__r � _in_queue)�self�args�kwds�� __class__� �Rc:\Users\shubh\Videos\agent\nova\Lib\site-packages\ipykernel/inprocess/blocking.pyr
16 s z!BlockingInProcessChannel.__init__c C s | j �|� dS )z Call the handlers for a message.N)r �put�r �msgr r r �
17 call_handlers s z&BlockingInProcessChannel.call_handlersTNc C s |du rd}| j �||�S )z-Gets a message if there is one that is ready.Ni�: )r �get)r �block�timeoutr r r �get_msg# s z BlockingInProcessChannel.get_msgc C s4 g } z |� | jdd�� W n
18 ty Y |S w q)z*Get all messages that are currently ready.TF)r )�appendr r )r Zmsgsr r r �get_msgs+ s ��z!BlockingInProcessChannel.get_msgsc C s | j �� S )z*Is there a message that has been received?)r �empty)r r r r � msg_ready5 s z"BlockingInProcessChannel.msg_ready)TN)
19 �__name__�
20 __module__� __qualname__�__doc__r
21 r r r r �
22 __classcell__r r r r r s
23
24 r c @ s e Zd ZdZdd� ZdS )� BlockingInProcessStdInChannelz$A blocking in-process stdin channel.c C sZ |d d }|dkr+| j jj}|d d }t|dtjd� tj�� | j �|� � dS dS ) zfOverridden for the in-process channel.
25
26 This methods simply calls raw_input directly.
27 �header�msg_typeZ
28 input_request�content�prompt� )�end�fileN)�clientZkernelZ_sys_raw_input�print�sys�
29 __stdout__�flush�input)r r r& �
30 _raw_inputr( r r r r = s
31
32 �z+BlockingInProcessStdInChannel.call_handlersN)r r r! r" r r r r r r$ : s r$ c @ s0 e Zd ZdZee�Zee�Zee�Z dd� Z
33 dS )� BlockingInProcessKernelClientz$A blocking in-process kernel client.c C s� | � � z
34 | jjddd�}W n ty Y n!w |d dkr9z
35 | jjddd� W n ty2 Y nw | �|� nq z| jjddd�}t|d � W n
36 tyU Y dS w q;)z,Wait for kernel info reply on shell channel.Tr )r r r& Zkernel_info_replyg�������?N)Z kernel_infoZ
37 shell_channelr r Z
38 iopub_channelZ_handle_kernel_info_replyr- r r r r �wait_for_readyS s0 � �
39 � ��z,BlockingInProcessKernelClient.wait_for_readyN) r r r! r" r r Zshell_channel_classZiopub_channel_classr$ Zstdin_channel_classr4 r r r r r3 K s r3 )r" r. �queuer r Z traitletsr Zchannelsr r, r r r$ r3 r r r r �<module> s #