File: //usr/local/lib/python3.7/test/test_asyncio/__pycache__/test_streams.cpython-37.pyc
B
��gj� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z y ddl Z W n e
k
r� dZ Y nX ddlZddlmZ G dd� dej�Zedkr�e�� dS ) zTests for streams.py.� N)�mock)�support)�utilsc sX e Zd ZdZ� fdd�Z� fdd�Ze�d�dd� �Zd d
� Z d d � Z
e j d
d� �Z
dd� Ze�edkd�dd� �Ze j e�edkd�dd� ��Zdd� Zdd� Ze j dd � �Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Z d)d*� Z d+d,� Z d-d.� Z d/d0� Z d1d2� Z!d3d4� Z"d5d6� Z#d7d8� Z$d9d:� Z%d;d<� Z&d=d>� Z'd?d@� Z(dAdB� Z)dCdD� Z*dEdF� Z+dGdH� Z,dIdJ� Z-dKdL� Z.dMdN� Z/dOdP� Z0dQdR� Z1dSdT� Z2dUdV� Z3dWdX� Z4dYdZ� Z5d[d\� Z6d]d^� Z7e j d_d`� �Z8e�e9j:dakdb�dcdd� �Z;dedf� Z<dgdh� Z=didj� Z>dkdl� Z?dmdn� Z@dodp� ZAdqdr� ZBdsdt� ZCdudv� ZDdwdx� ZEdydz� ZFd{d|� ZGd}d~� ZHdd�� ZI� ZJS )�� StreamTestss line1
line2
line3
c s$ t � �� t�� | _| �| j� d S )N)�super�setUp�asyncioZnew_event_loop�loop�set_event_loop)�self)� __class__� �:/usr/local/lib/python3.7/test/test_asyncio/test_streams.pyr s
zStreamTests.setUpc s, t �| j� | j�� t�� t� �� d S )N)�
test_utils� run_brieflyr �close�gcZcollectr �tearDown)r )r r
r r s
zStreamTests.tearDownzasyncio.streams.eventsc C s t �� }| �|j|jj� d S )N)r � StreamReader�assertIs�_loopZget_event_loop� return_value)r Zm_events�streamr
r
r �test_ctor_global_loop' s z!StreamTests.test_ctor_global_loopc C sj | j �|�\}}|�d� |�� }| j �|�}| �|d� |�� }| j �|�}| �|�d�� |�� d S )Ns GET / HTTP/1.0
s HTTP/1.0 200 OK
s
Test message) r �run_until_complete�write�readline� assertEqual�read�
assertTrue�endswithr )r �open_connection_fut�reader�writer�f�datar
r
r �_basetest_open_connection, s
z%StreamTests._basetest_open_connectionc C s6 t �� �$}tj|jd| ji�}| �|� W d Q R X d S )Nr )r �run_test_serverr �open_connection�addressr r& )r �httpd�conn_futr
r
r �test_open_connection7 s
z StreamTests.test_open_connectionc C s4 t �� �"}tj|j| jd�}| �|� W d Q R X d S )N)r )r �run_test_unix_serverr �open_unix_connectionr) r r& )r r* r+ r
r
r �test_open_unix_connection= s
z%StreamTests.test_open_unix_connectionc C s\ z| j �|�\}}W d t�d � X |�d� |�� }| j �|�}| �|�d�� |�� d S )Ns GET / HTTP/1.0
s
Test message) r r r r
r r r r r )r r! r" r# r$ r% r
r
r �%_basetest_open_connection_no_loop_sslD s
z1StreamTests._basetest_open_connection_no_loop_sslNz
No ssl modulec C s@ t jdd��*}tj|jt �� | jd��}| �|� W d Q R X d S )NT)�use_ssl)�sslr )r r' r r( r) �dummy_ssl_contextr r0 )r r* r+ r
r
r � test_open_connection_no_loop_sslP s z,StreamTests.test_open_connection_no_loop_sslc C s@ t jdd��*}tj|jt �� d| jd�}| �|� W d Q R X d S )NT)r1 � )r2 Zserver_hostnamer )r r- r r. r) r3 r r0 )r r* r+ r
r
r �%test_open_unix_connection_no_loop_sslZ s
z1StreamTests.test_open_unix_connection_no_loop_sslc C s` | j �|�\}}|j�t� � |�� }| �t�� | j �|� W d Q R X |�� t� | j � d S )N)
r r Z _protocolZconnection_lost�ZeroDivisionErrorr � assertRaisesr r r )r r! r" r# r$ r
r
r � _basetest_open_connection_errorf s z+StreamTests._basetest_open_connection_errorc C s6 t �� �$}tj|jd| ji�}| �|� W d Q R X d S )Nr )r r' r r( r) r r9 )r r* r+ r
r
r �test_open_connection_erroro s
z&StreamTests.test_open_connection_errorc C s4 t �� �"}tj|j| jd�}| �|� W d Q R X d S )N)r )r r- r r. r) r r9 )r r* r+ r
r
r � test_open_unix_connection_erroru s
z+StreamTests.test_open_unix_connection_errorc C s* t j| jd�}|�d� | �d|j� d S )N)r � )r r r � feed_datar �_buffer)r r r
r
r �test_feed_empty_data| s
z StreamTests.test_feed_empty_datac C s. t j| jd�}|�| j� | �| j|j� d S )N)r )r r r r= �DATAr r> )r r r
r
r �test_feed_nonempty_data� s z#StreamTests.test_feed_nonempty_datac C sL t j| jd�}|�| j� | j�|�d��}| �d|� | �| j|j� d S )N)r r r< ) r r r r= r@ r r r r> )r r r% r
r
r �test_read_zero� s
zStreamTests.test_read_zeroc sj t j� jd��t j��d�� jd�}� �fdd�}� j�|� � j�|�}� �� j|� � �d�j � d S )N)r � c s �� � j� d S )N)r= r@ r
)r r r
r �cb� s z!StreamTests.test_read.<locals>.cbr< )
r r r �Taskr � call_soonr r r@ r> )r � read_taskrD r% r
)r r r � test_read� s zStreamTests.test_readc C sR t j| jd�}|�d� |�d� | j�|�d��}| �d|� | �d|j� d S )N)r s line1s line2� )r r r r= r r r r> )r r r% r
r
r �test_read_line_breaks� s
z!StreamTests.test_read_line_breaksc sf t j| jd�� t j� �d�| jd�}� fdd�}| j�|� | j�|�}| �d|� | �d� j� d S )N)r i c s � � � d S )N)�feed_eofr
)r r
r rD � s z%StreamTests.test_read_eof.<locals>.cbr< ) r r r rE r rF r r r> )r rG rD r% r
)r r �
test_read_eof� s zStreamTests.test_read_eofc sf t j| jd�� t j� �d�| jd�}� fdd�}| j�|� | j�|�}| �d|� | �d� j� d S )N)r ���c s � � d� � � d� � �� d S )Ns chunk1
s chunk2)r= rK r
)r r
r rD � s
z+StreamTests.test_read_until_eof.<locals>.cbs
chunk1
chunk2r< ) r r r rE r rF r r r> )r rG rD r% r
)r r �test_read_until_eof� s z StreamTests.test_read_until_eofc C s^ t j| jd�}|�d� | j�|�d��}| �d|� |�t� � | � t| jj|�d�� d S )N)r s line
� s li)
r r r r= r r r �
set_exception�
ValueErrorr8 )r r r% r
r
r �test_read_exception� s
z StreamTests.test_read_exceptionc C sT | � td�� tjd| jd� W d Q R X | � td�� tjd| jd� W d Q R X d S )NZimitr )�limitr rM )�assertRaisesRegexrQ r r r )r r
r
r �test_invalid_limit� s z StreamTests.test_invalid_limitc C sJ t jd| jd�}|�d� | j�|�d��}| �d|� | �d|j� d S )N� )rS r s chunkrI r< )r r r r= r r r r> )r r r% r
r
r �test_read_limit� s
zStreamTests.test_read_limitc sn t j| jd�� � �d� t j� �� | jd�}� fdd�}| j�|� | j�|�}| �d|� | �d� j � d S )N)r s chunk1 c s" � � d� � � d� � � d� d S )Ns chunk2 s chunk3 s
chunk4)r= r
)r r
r rD � s
z%StreamTests.test_readline.<locals>.cbs chunk1 chunk2 chunk3
s chunk4)
r r r r= rE r rF r r r> )r rG rD �liner
)r r �
test_readline� s
zStreamTests.test_readlinec C s� t jd| jd�}|�d� |�d� | �t| jj|�� � | �d|j � t jd| jd�}|�d� |�d� |�d� | �t| jj|�� � | �d|j � d S )NrV )rS r s lis
ne1
line2
s line2
s ne1r< )
r r r r= r8 rQ r r r r> )r r r
r
r �&test_readline_limit_with_existing_data� s
z2StreamTests.test_readline_limit_with_existing_datac C s� t j| jd�}| �|�� � |�d� | �|�� � | j�|�� � | �|�� � |�d� |�� | j�|�� � | � |�� � d S )N)r s
some data
)
r r r � assertFalseZat_eofr= r r rK r )r r r
r
r � test_at_eof s
zStreamTests.test_at_eofc s\ t jd| jd�� � fdd�}| j�|� | �t| jj� �� � | �d� j � t jd| jd�� � fdd�}| j�|� | �t| jj� �� � | �d� j � t jd| jd�� � �
d� | j�� �� �}| �d|� | �d� j � � �
d � | �t��}| j�� �� � W d Q R X | �d� j � � �
d
� | �t��}| j�� �� � W d Q R X | �d� j � d S ) N� )rS r c s* � � d� � � d� � � d� � �� d S )Ns chunk1s chunk2s chunk3
)r= rK r
)r r
r rD s
z+StreamTests.test_readline_limit.<locals>.cbr< c s* � � d� � � d� � � d� � �� d S )Ns chunk1s chunk2
s chunk3
)r= rK r
)r r
r rD - s
s chunk3
s 1234567
s 12345678
s 12345678) r r r rF r8 rQ r r r r> r= )r rD rX �cmr
)r r �test_readline_limit s2
z StreamTests.test_readline_limitc C sd t j| jd�}|�| jd d� � |�| jdd � � | j�|�� �}| �d|� | �d|j� d S )N)r � s line1
s line2
line3
) r r r r= r@ r r r r> )r r rX r
r
r � test_readline_nolimit_nowaitI s z(StreamTests.test_readline_nolimit_nowaitc C s@ t j| jd�}|�d� |�� | j�|�� �}| �d|� d S )N)r s some data)r r r r= rK r r r )r r rX r
r
r �test_readline_eofU s
z StreamTests.test_readline_eofc C s6 t j| jd�}|�� | j�|�� �}| �d|� d S )N)r r< )r r r rK r r r )r r rX r
r
r �test_readline_empty_eof] s z#StreamTests.test_readline_empty_eofc C sZ t j| jd�}|�| j� | j�|�� � | j�|�d��}| �d|� | �d|j � d S )N)r r] s line2
ls ine3
)
r r r r= r@ r r r r r> )r r r% r
r
r � test_readline_read_byte_countd s z)StreamTests.test_readline_read_byte_countc C sh t j| jd�}|�d� | j�|�� �}| �d|� |�t� � | � t| jj|�� � | �d|j
� d S )N)r s line
r< ) r r r r= r r r rP rQ r8 r> )r r r% r
r
r �test_readline_exceptiono s
z#StreamTests.test_readline_exceptionc C s> t j| jd�}| �td�� | j�|jdd�� W d Q R X d S )N)r zSeparator should ber< )� separator)r r r rT rQ r � readuntil)r r r
r
r �test_readuntil_separator{ s z$StreamTests.test_readuntil_separatorc C s� t j| jd�}|�d� | j�|jdd��}| �d|� | �d|j� |�d� | j�|�d��}| �d|� | �d|j� |�d� | j�|�d��}| �d|� | �d|j� d S )N)r s lineAAAs AAA)rf r< s
lineAAAxxxs xxx)r r r r= r rg r r> )r r r% r
r
r �test_readuntil_multi_chunks� s
z'StreamTests.test_readuntil_multi_chunksc C sf t j| jd�}|�d� |�d� |�d� | j�|�d��}| �d|� | �d|j� |�d� |�d� |�d � | j�|�d��}| �d|� | �d|j� |�d� | j�|�d��}| �d|� | �d|j� |�d
� | j�|�d��}| �d
|� | �d|j� |�d � |�d� |�d� |�d� | j�|�d��}| �d |� | �d|j� d S )
N)r s QWEaas XYaa� as aaas
QWEaaXYaaar< s XYas aas Xaaas XXXs XXXaaa)r r r r= r rg r r> )r r r% r
r
r � test_readuntil_multi_chunks_1� s8
z)StreamTests.test_readuntil_multi_chunks_1c C sz t j| jd�}|�d� |�� | �t j��}| j�|�d�� W d Q R X | � |j
j d� | � |j
j
� | � d|j� d S )N)r s some dataAAs AAAr< )r r r r= rK r8 �IncompleteReadErrorr rg r � exception�partial� assertIsNone�expectedr> )r r r^ r
r
r �test_readuntil_eof� s
z StreamTests.test_readuntil_eofc C s� t j| jdd�}|�d� | �t jd��}| j�|�d�� W d Q R X | �d|j � |�d� | �t jd��}| j�|�d�� W d Q R X | �d|j � d S ) NrV )r rS s some dataAAz not founds AAA� Azis founds some dataAAA)
r r r r= rT �LimitOverrunErrorr rg r r> )r r r^ r
r
r � test_readuntil_limit_found_sep� s
z*StreamTests.test_readuntil_limit_found_sepc C s� t j| jd�}|�| j� | j�|�d��}| �d|� | �| j|j� | � t
d�� | j�|�d�� W d Q R X | �| j|j� d S )N)r r r< zless than zerorM ) r r r r= r@ r � readexactlyr r> rT rQ )r r r% r
r
r � test_readexactly_zero_or_less� s z)StreamTests.test_readexactly_zero_or_lessc s� t j� jd��dt� j� }t j��|�� jd�}� �fdd�}� j�|� � j�|�}� � � j� j |� � � � j�j
� d S )N)r rO c s( �� � j� �� � j� �� � j� d S )N)r= r@ r
)r r r
r rD � s z(StreamTests.test_readexactly.<locals>.cb) r r r �lenr@ rE ru rF r r r> )r �nrG rD r% r
)r r r �test_readexactly� s z StreamTests.test_readexactlyc C sJ t jd| jd�}|�d� | j�|�d��}| �d|� | �d|j� d S )NrV )rS r s chunkrI r< )r r r r= r ru r r> )r r r% r
r
r �test_readexactly_limit� s
z"StreamTests.test_readexactly_limitc s� t j� jd��dt� j� }t j��|�� jd�}� �fdd�}� j�|� � �t j ��}� j�
|� W d Q R X � � |j j
� j� � � |j j|� � � t|j �d� � � d�j� d S )N)r rO c s �� � j� ��� d S )N)r= r@ rK r
)r r r
r rD � s z,StreamTests.test_readexactly_eof.<locals>.cbz-18 bytes read on a total of 36 expected bytesr< )r r r rw r@ rE ru rF r8 rl r r rm rn rp �strr> )r rx rG rD r^ r
)r r r �test_readexactly_eof� s z StreamTests.test_readexactly_eofc C s^ t j| jd�}|�d� | j�|�d��}| �d|� |�t� � | � t| jj|�d�� d S )N)r s line
rO s li)
r r r r= r ru r rP rQ r8 )r r r% r
r
r �test_readexactly_exception s
z&StreamTests.test_readexactly_exceptionc C s@ t j| jd�}| �|�� � t� }|�|� | �|�� |� d S )N)r )r r r ro rm rQ rP r )r r �excr
r
r �test_exception s
zStreamTests.test_exceptionc st t j| jd�� t j� fdd��}t j� �� | jd�}t j|� | jd�}| j�t j||g| jd�� | �t |j
� d S )N)r c s � � t� � d S )N)rP rQ r
)r r
r �set_err s z2StreamTests.test_exception_waiter.<locals>.set_err) r r r � coroutinerE r r �waitr8 rQ �result)r r� Zt1Zt2r
)r r �test_exception_waiter s z!StreamTests.test_exception_waiterc C sn t j| jd�}t j|�� | jd�}t�| j� |�� t�| j� |�t d�� t�| j� | �
|j d � d S )N)r �message) r r r rE r r r ZcancelrP � RuntimeErrorr �_waiter)r r �tr
r
r �test_exception_cancel* s z!StreamTests.test_exception_cancelc s� G dd� d�}� fdd�}|� j �}|�� }� j �tj||�� j d��}|�� � �|d� |� j �}|�� }� j �tj||�� j d��}|�� � �|d� d S )Nc @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )z/StreamTests.test_start_server.<locals>.MyServerc S s d | _ || _d S )N)�serverr )r r r
r
r �__init__: s z8StreamTests.test_start_server.<locals>.MyServer.__init__c � s2 |� � I d H }|�|� |�� I d H |�� d S )N)r r �drainr )r �
client_reader�
client_writerr% r
r
r �
handle_client> s
z=StreamTests.test_start_server.<locals>.MyServer.handle_clientc S s8 t � � }|�d� | j�tj| j|| jd��| _|�� S )N)z 127.0.0.1r )�sockr ) �socket�bindr r r � start_serverr� r� � getsockname)r r� r
r
r �startD s
z5StreamTests.test_start_server.<locals>.MyServer.startc S s | j �| �||�� d S )N)r � create_taskr� )r r� r� r
r
r �handle_client_callbackM s zFStreamTests.test_start_server.<locals>.MyServer.handle_client_callbackc S sN t � � }|�d� |�� }|�� | j�tj| j|d |d | jd��| _ |S )N)z 127.0.0.1r r � )�host�portr )
r� r� r� r r r r r� r� r� )r r� �addrr
r
r �start_callbackQ s
z>StreamTests.test_start_server.<locals>.MyServer.start_callbackc S s0 | j d k r,| j �� | j�| j �� � d | _ d S )N)r� r r r � wait_closed)r r
r
r �stop\ s
z4StreamTests.test_start_server.<locals>.MyServer.stopN) �__name__�
__module__� __qualname__r� r� r� r� r� r� r
r
r
r �MyServer8 s r� c � s@ t j| d� ji�I d H \}}|�d� |�� I d H }|�� |S )Nr s
hello world!
)r r( r r r r )r� r" r# �msgback)r r
r �clientb s
z-StreamTests.test_start_server.<locals>.client)r s
hello world!
)r r� r r rE r� r r� )r r� r� r� r� �msgr
)r r �test_start_server6 s *
z StreamTests.test_start_serverc s� G dd� d�}� fdd�}t �� �J}|� j|�}|�� � j�tj||�� jd��}|�� � �|d� W d Q R X t �� �J}|� j|�}|� � � j�tj||�� jd��}|�� � �|d� W d Q R X d S )Nc @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )z4StreamTests.test_start_unix_server.<locals>.MyServerc S s d | _ || _|| _d S )N)r� r �path)r r r� r
r
r r� � s z=StreamTests.test_start_unix_server.<locals>.MyServer.__init__c � s2 |� � I d H }|�|� |�� I d H |�� d S )N)r r r� r )r r� r� r% r
r
r r� � s
zBStreamTests.test_start_unix_server.<locals>.MyServer.handle_clientc S s$ | j �tj| j| j| j d��| _d S )N)r� r )r r r �start_unix_serverr� r� r� )r r
r
r r� � s z:StreamTests.test_start_unix_server.<locals>.MyServer.startc S s | j �| �||�� d S )N)r r� r� )r r� r� r
r
r r� � s zKStreamTests.test_start_unix_server.<locals>.MyServer.handle_client_callbackc S s( t j| j| j| jd�}| j�|�| _d S )N)r� r )r r� r� r� r r r� )r r� r
r
r r� � s
zCStreamTests.test_start_unix_server.<locals>.MyServer.start_callbackc S s0 | j d k r,| j �� | j�| j �� � d | _ d S )N)r� r r r r� )r r
r
r r� � s
z9StreamTests.test_start_unix_server.<locals>.MyServer.stopN) r� r� r� r� r� r� r� r� r� r
r
r
r r� s r� c � s> t j| � jd�I d H \}}|�d� |�� I d H }|�� |S )N)r s
hello world!
)r r. r r r r )r� r" r# r� )r r
r r� � s
z2StreamTests.test_start_unix_server.<locals>.client)r s
hello world!
)
r Zunix_socket_pathr r� r r rE r� r r� )r r� r� r� r� r� r
)r r �test_start_unix_server| s #
z"StreamTests.test_start_unix_server�win32zDon't have pipesc
s� d}t �� \}}tjd|t|�g}t|dd�}tj| jdd�}tj || jd�� | j�
| j� � fdd �|��\}}t� � } | �
| j� z@t�| � tj||h| jd
��}
| j�
|
�} | j�
| �� � W d t�d � X t �|� | j�
|�d ��} | �| d � d S )
NzHimport os, sys
fd = int(sys.argv[1])
os.write(fd, b'data')
os.close(fd)
z-c�rbr r� )r rS )r c s � S )Nr
r
)�protocolr
r �<lambda>� r< z<StreamTests.test_read_all_from_pipe_reader.<locals>.<lambda>)Zpass_fdsr rM s data)�os�pipe�sys�
executabler{ �openr r r �StreamReaderProtocolr Zconnect_read_pipeZSafeChildWatcherZ attach_loopZset_child_watcherZcreate_subprocess_execr� r r r )
r �codeZrfdZwfd�argsr� r" Z transport�_ZwatcherZcreate�procr% r
)r� r � test_read_all_from_pipe_reader� s*
z*StreamTests.test_read_all_from_pipe_readerc C s6 | � tjd � t�| j� t�� }| �|j| j� d S )N)�
addCleanupr r
r r r r )r r" r
r
r � test_streamreader_constructor� s z)StreamTests.test_streamreader_constructorc C s@ | � tjd � t�| j� t�� }t�|�}| �|j| j� d S )N) r� r r
r r �Mockr� r r )r r" r� r
r
r �%test_streamreaderprotocol_constructor� s
z1StreamTests.test_streamreaderprotocol_constructorc s| t �� � � fdd�}�fdd�}tj|d�}|�d� |�� � �� }��tt f�� �j
� ||� � W d Q R X |� � d S )Nc sV t � � } | �@ | �d� | �d� | �� }� �|� | �� \}}|�� W d Q R X d S )N)Z localhostr r� )r� r� Zlistenr� ZputZacceptr )r� r� Zcltr� )�qr
r r� s
z-StreamTests.test_drain_raises.<locals>.serverc � s> t j| |� jd�I d H \}}x |�d� |�� I d H q W d S )N)r s foo
)r r( r r r� )r� r� r" r# )r r
r r�
s
z-StreamTests.test_drain_raises.<locals>.client)�targetT)
�queueZQueue� threadingZThreadZ setDaemonr� �getr8 �ConnectionResetError�BrokenPipeErrorr r �join)r r� r� Zthreadr� r
)r� r r �test_drain_raises� s
z StreamTests.test_drain_raisesc C s" t j| jd�}| �dt|�� d S )N)r z<StreamReader>)r r r r �repr)r r r
r
r �
test___repr__# s zStreamTests.test___repr__c C s$ t j| jdd�}| �dt|�� d S )N�{ )r rS z<StreamReader limit=123>)r r r r r� )r r r
r
r � test___repr__nondefault_limit' s z)StreamTests.test___repr__nondefault_limitc C s* t j| jd�}|�� | �dt|�� d S )N)r z<StreamReader eof>)r r r rK r r� )r r r
r
r �test___repr__eof+ s z StreamTests.test___repr__eofc C s, t j| jd�}|�d� | �dt|�� d S )N)r s dataz<StreamReader 4 bytes>)r r r r= r r� )r r r
r
r �test___repr__data0 s
z StreamTests.test___repr__datac C s2 t j| jd�}t� }|�|� | �dt|�� d S )N)r z'<StreamReader exception=RuntimeError()>)r r r r� rP r r� )r r r~ r
r
r �test___repr__exception5 s
z"StreamTests.test___repr__exceptionc C sb t j| jd�}t j| jd�|_| �t|�d� |j�d � | j�|j� d |_| � dt|�� d S )N)r z,<StreamReader waiter=<Future pending[\S ]*>>z<StreamReader>)
r r r ZFuturer� Z assertRegexr� Z
set_resultr r )r r r
r
r �test___repr__waiter< s z StreamTests.test___repr__waiterc C sB t j| jd�}t�� |_t�� |j_d|jj_| �dt |�� d S )N)r z <Transport>z$<StreamReader transport=<Transport>>)
r r r r r� Z
_transport�__repr__r r r� )r r r
r
r �test___repr__transportG s
z"StreamTests.test___repr__transportc
C s� t �dd�}xvttjd �D ]d}| j|d��N t�tj||d��}| �t |�t |�� | �|j
|j
� | �|j |j � W d Q R X q W d S )Ns abc�
r� )�pickle_protocol)r� ) r rl �range�pickle�HIGHEST_PROTOCOL�subTest�loads�dumpsr r{ rn rp )r �e�proto�e2r
r
r �#test_IncompleteReadError_pickleableN s z/StreamTests.test_IncompleteReadError_pickleablec
C sx t �dd�}xfttjd �D ]T}| j|d��> t�tj||d��}| �t |�t |�� | �|j
|j
� W d Q R X q W d S )Nr� r� r� )r� )r� ) r rs r� r� r� r� r� r� r r{ �consumed)r r� r� r� r
r
r �!test_LimitOverrunError_pickleableW s z-StreamTests.test_LimitOverrunError_pickleablec C s� t �� ��}| j�tj|jd| ji��\}}|�d� |�� }| j�|�}| � |d� |�
� }| j�|�}| � |� d�� | �
|�� � |�� | � |�� � | j�|�� � W d Q R X d S )Nr s GET / HTTP/1.0
s HTTP/1.0 200 OK
s
Test message)r r' r r r r( r) r r r r r r r[ Z
is_closingr r� )r r* �rd�wrr$ r% r
r
r �test_wait_closed_on_close_ s
z%StreamTests.test_wait_closed_on_closec C sz t �� �h}| j�tj|jd| ji��\}}|�d� |�� }| j�|�}| � |d� |�
� | j�|� � � W d Q R X d S )Nr s GET / HTTP/1.0
s HTTP/1.0 200 OK
) r r' r r r r( r) r r r r r� )r r* r� r� r$ r% r
r
r �*test_wait_closed_on_close_with_unread_datap s
z6StreamTests.test_wait_closed_on_close_with_unread_data)Kr� r� r� r@ r r r Zpatchr r& r, r Z skip_unless_bind_unix_socketr/ r0 �unittestZskipIfr2 r4 r6 r9 r: r; r? rA rB rH rJ rL rN rR rU rW rY rZ r\ r_ ra rb rc rd re rh ri rk rq rt rv ry rz r| r} r r� r� r� r� r� �platformr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �
__classcell__r
r
)r r r s~
/ #
FB'
+ r �__main__)�__doc__r r� r� r� r� r� r� r� r Ztestr r2 � ImportErrorr Ztest.test_asyncior r ZTestCaser r� �mainr
r
r
r �<module> s2
m