File: //usr/local/lib/python3.6/site-packages/pexpect/__pycache__/_async.cpython-36.pyc
3
��Zd� � @ sZ d dl Z d dlZd dlZd dlmZ e jd
dd��Ze jd dd��ZG dd � d e j�Z dS )
� N)�EOFc # s� | j � }|d k r|S | jjs^t� � � j| � tj� j� fdd�| j�E d H \}� � |f| j_n | jj\� }� j| � |j� ytj � j
|�E d H S tj k
r� } z|j � | j
|�S d }~X nX d S )Nc s � S )N� r )�pwr �1/tmp/pip-build-hc5bmb4z/pexpect/pexpect/_async.py�<lambda> s z expect_async.<locals>.<lambda>)Z
existing_data�spawnZasync_pw_transport�
PatternWaiter� set_expecter�asyncioZget_event_loopZconnect_read_pipeZresume_reading�wait_for�fut� TimeoutError�
pause_reading�timeout)�expecterr �idx� transport�er )r r � expect_async s"
r � c c s� g }| j j|d � xB|dd � D ]2}| j|dd�E d H |j| j j� | j j|� q"W | j|dd�E d H }|dkr�| j jtj� | jddd�E d H td��dj || j jg �S )Nr r T)r Zasync_z1Continuation prompt found - input was incomplete:� )
�childZsendlineZ_expect_prompt�appendZbefore�kill�signal�SIGINT�
ValueError�join)�replZcmdlinesr �res�lineZ
prompt_idxr r r �repl_run_command_async s r! c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )r Nc C s || _ tj� | _d S )N)r r
ZFuturer )�selfr r r r r 3 s zPatternWaiter.set_expecterc C s$ | j j� s | j j|� | jj� d S )N)r �doneZ
set_resultr r )r" �resultr r r �found7 s
zPatternWaiter.foundc C s$ | j j� s | j j|� | jj� d S )N)r r# Z
set_exceptionr r )r" �excr r r �error< s
zPatternWaiter.errorc C s
|| _ d S )N)r )r" r r r r �connection_madeA s z PatternWaiter.connection_madec C s� | j j}|jj|�}|j|d� | jj� rF|jj|� |j j|� d S y"| j j
|�}|d k rf| j |� W n6 t k
r� } z| j j
� | j|� W Y d d }~X nX d S )N�read)r r �_decoder�decode�_logr r# Z_before�write�_bufferZnew_datar% � ExceptionZerroredr' )r" �datar �s�indexr r r r �
data_receivedD s
zPatternWaiter.data_receivedc C sT yd| j j_| j j� }W n, tk
rD } z| j|� W Y d d }~X n X | j|� d S )NT)r r Zflag_eof�eofr r' r% )r" r2 r r r r � eof_receivedW s
zPatternWaiter.eof_receivedc C s6 t |t�r |jtjkr | j� n|d k r2| j|� d S )N)�
isinstance�OSError�errnoZEIOr5 r' )r" r& r r r �connection_lostb s
z PatternWaiter.connection_lost) �__name__�
__module__� __qualname__r r r% r' r( r3 r5 r9 r r r r r 0 s r )N���)r= )
r
r8 r Zpexpectr � coroutiner r! ZProtocolr r r r r �<module> s