| Server IP : 118.27.122.248 / Your IP : 216.73.216.40 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python36/lib64/python3.6/test/test_asyncio/__pycache__/ |
Upload File : |
3
�w2_^~ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z y ddl
Z
W n e k
rt dZ
Y nX ddl Z ddl m
Z
G dd� de
j�Zedkr�ej� dS )zTests for streams.py.� N)�mock)�
test_utilsc sx e Zd ZdZ� fdd�Z� fdd�Zejd�dd� �Zd d
� Z d d � Z
e j e
ed
�d�dd� �Zdd� Ze jedkd�dd� �Ze jedkd�e j e
ed
�d�dd� ��Zdd� Zdd � Ze j e
ed
�d�d 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^� Z7d_d`� Z8e j e
ed
�d�dadb� �Z9e je:j;dckdd�dedf� �Z<dgdh� Z=didj� Z>dkdl� Z?dmdn� Z@dodp� ZAdqdr� ZBdsdt� ZCdudv� ZDdwdx� ZEdydz� ZFd{d|� ZGd}d~� ZH� ZIS )�StreamReaderTestss line1
line2
line3
c s$ t � j� tj� | _| j| j� d S )N)�super�setUp�asyncioZnew_event_loop�loop�set_event_loop)�self)� __class__� �C/opt/alt/python36/lib64/python3.6/test/test_asyncio/test_streams.pyr s
zStreamReaderTests.setUpc s, t j| j� | jj� tj� t� j� d S )N)r � run_brieflyr �close�gcZcollectr �tearDown)r
)r r r
r s
zStreamReaderTests.tearDownzasyncio.streams.eventsc C s t j� }| j|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'StreamReaderTests.test_ctor_global_loopc C sj | j j|�\}}|jd� |j� }| j j|�}| j|d� |j� }| j j|�}| j|jd�� |j� 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+StreamReaderTests._basetest_open_connectionc C s6 t j� �$}tj|jd| ji�}| j|� W d Q R X d S )Nr )r �run_test_serverr �open_connection�addressr r$ )r
�httpd�conn_futr r r
�test_open_connection6 s
z&StreamReaderTests.test_open_connectionZAF_UNIXzNo UNIX Socketsc C s4 t j� �"}tj|j| jd�}| j|� 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+StreamReaderTests.test_open_unix_connectionc C s\ z| j j|�\}}W d tjd � X |jd� |j� }| j j|�}| j|jd�� |j� 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_sslC s
z7StreamReaderTests._basetest_open_connection_no_loop_sslNz
No ssl modulec C s@ t jdd��*}tj|jt j� | jd��}| j|� W d Q R X d S )NT)�use_ssl)�sslr )r r% r r& r' �dummy_ssl_contextr r. )r
r( r) r r r
� test_open_connection_no_loop_sslO s z2StreamReaderTests.test_open_connection_no_loop_sslc
C s@ t jdd��*}tj|jt j� d| jd�}| j|� W d Q R X d S )NT)r/ � )r0 Zserver_hostnamer )r r+ r r, r' r1 r r. )r
r( r) r r r
�%test_open_unix_connection_no_loop_sslY s
z7StreamReaderTests.test_open_unix_connection_no_loop_sslc C s` | j j|�\}}|jjt� � |j� }| jt�� | j j|� W d Q R X |j� tj | j � d S )N)
r r Z _protocolZconnection_lost�ZeroDivisionErrorr � assertRaisesr r r )r
r r r! r" r r r
� _basetest_open_connection_errore s z1StreamReaderTests._basetest_open_connection_errorc C s6 t j� �$}tj|jd| ji�}| j|� W d Q R X d S )Nr )r r% r r& r' r r7 )r
r( r) r r r
�test_open_connection_errorn s
z,StreamReaderTests.test_open_connection_errorc C s4 t j� �"}tj|j| jd�}| j|� W d Q R X d S )N)r )r r+ r r, r' r r7 )r
r( r) r r r
� test_open_unix_connection_errort s
z1StreamReaderTests.test_open_unix_connection_errorc C s* t j| jd�}|jd� | jd|j� d S )N)r � )r r r � feed_datar �_buffer)r
r r r r
�test_feed_empty_data{ s
z&StreamReaderTests.test_feed_empty_datac C s. t j| jd�}|j| j� | j| j|j� d S )N)r )r r r r; �DATAr r< )r
r r r r
�test_feed_nonempty_data� s z)StreamReaderTests.test_feed_nonempty_datac C sL t j| jd�}|j| j� | jj|jd��}| jd|� | j| 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
z StreamReaderTests.test_read_zeroc sj t j� jd��t j�jd�� jd�}� �fdd�}� jj|� � jj|�}� j� j|� � jd�j � d S )N)r � c s �j � j� d S )N)r; r> r )r
r r r
�cb� s z'StreamReaderTests.test_read.<locals>.cbr: )
r r r �Taskr � call_soonr r r> r< )r
� read_taskrB r# r )r
r r
� test_read� s zStreamReaderTests.test_readc C sR t j| jd�}|jd� |jd� | jj|jd��}| jd|� | jd|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'StreamReaderTests.test_read_line_breaksc sf t j| jd�� t j� jd�| jd�}� fdd�}| jj|� | jj|�}| jd|� | jd� j� d S )N)r i c s � j � d S )N)�feed_eofr )r r r
rB � s z+StreamReaderTests.test_read_eof.<locals>.cbr: ) r r r rC r rD r r r< )r
rE rB r# r )r r
�
test_read_eof� s z StreamReaderTests.test_read_eofc sf t j| jd�� t j� jd�| jd�}� fdd�}| jj|� | jj|�}| jd|� | jd� j� d S )N)r � c s � j d� � j d� � j� d S )Ns chunk1
s chunk2)r; rI r )r r r
rB � s
z1StreamReaderTests.test_read_until_eof.<locals>.cbs
chunk1
chunk2r: ���) r r r rC r rD r r r< )r
rE rB r# r )r r
�test_read_until_eof� s z%StreamReaderTests.test_read_until_eofc C s^ t j| jd�}|jd� | jj|jd��}| jd|� |jt� � | j t| jj|jd�� d S )N)r s line
� s li)
r r r r; r r r �
set_exception�
ValueErrorr6 )r
r r# r r r
�test_read_exception� s
z%StreamReaderTests.test_read_exceptionc C sT | j td�� tjd| jd� W d Q R X | j td�� tjd| jd� W d Q R X d S )NZimitr )�limitr rK rL )�assertRaisesRegexrP r r r )r
r r r
�test_invalid_limit� s z$StreamReaderTests.test_invalid_limitc C sJ t jd| jd�}|jd� | jj|jd��}| jd|� | jd|j� d S )N� )rR r s chunkrG r: )r r r r; r r r r< )r
r r# r r r
�test_read_limit� s
z!StreamReaderTests.test_read_limitc sn t j| jd�� � jd� t j� j� | jd�}� fdd�}| jj|� | jj|�}| jd|� | jd� j � d S )N)r s chunk1 c s" � j d� � j d� � j d� d S )Ns chunk2 s chunk3 s
chunk4)r; r )r r r
rB � s
z+StreamReaderTests.test_readline.<locals>.cbs chunk1 chunk2 chunk3
s chunk4)
r r r r; rC r rD r r r< )r
rE rB �liner )r r
�
test_readline� s
z StreamReaderTests.test_readlinec C s� t jd| jd�}|jd� |jd� | jt| jj|j� � | jd|j � t jd| jd�}|jd� |jd� |jd� | jt| jj|j� � | jd|j � d S )NrU )rR r s lis
ne1
line2
s line2
s ne1r: )
r r r r; r6 rP r r r r< )r
r r r r
�&test_readline_limit_with_existing_data� s
z8StreamReaderTests.test_readline_limit_with_existing_datac C s� t j| jd�}| j|j� � |jd� | j|j� � | jj|j� � | j|j� � |jd� |j� | jj|j� � | j |j� � d S )N)r s
some data
)
r r r Z assertFalseZat_eofr; r r rI r )r
r r r r
� test_at_eof
s
z StreamReaderTests.test_at_eofc s\ t jd| jd�� � fdd�}| jj|� | jt| jj� j� � | jd� j � t jd| jd�� � fdd�}| jj|� | jt| jj� j� � | jd� j � t jd| jd�� � j
d� | jj� j� �}| jd|� | jd� j � � j
d � | jt��}| jj� j� � W d Q R X | jd� j � � j
d
� | jt��}| jj� j� � W d Q R X | jd� j � d S ) N� )rR r c s* � j d� � j d� � j d� � j� d S )Ns chunk1s chunk2s chunk3
)r; rI r )r r r
rB s
z1StreamReaderTests.test_readline_limit.<locals>.cbr: c s* � j d� � j d� � j d� � j� d S )Ns chunk1s chunk2
s chunk3
)r; rI r )r r r
rB , s
s chunk3
s 1234567
s 12345678
s 12345678) r r r rD r6 rP r r r r< r; )r
rB rW �cmr )r r
�test_readline_limit s2
z%StreamReaderTests.test_readline_limitc C sd t j| jd�}|j| jd d� � |j| jdd � � | jj|j� �}| jd|� | jd|j� d S )N)r � s line1
s line2
line3
) r r r r; r> r r r r< )r
r rW r r r
� test_readline_nolimit_nowaitH s z.StreamReaderTests.test_readline_nolimit_nowaitc C s@ t j| jd�}|jd� |j� | jj|j� �}| jd|� d S )N)r s some data)r r r r; rI r r r )r
r rW r r r
�test_readline_eofT s
z#StreamReaderTests.test_readline_eofc C s6 t j| jd�}|j� | jj|j� �}| jd|� d S )N)r r: )r r r rI r r r )r
r rW r r r
�test_readline_empty_eof\ s z)StreamReaderTests.test_readline_empty_eofc C sZ t j| jd�}|j| j� | jj|j� � | jj|jd��}| jd|� | jd|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_countc s z/StreamReaderTests.test_readline_read_byte_countc C sh t j| jd�}|jd� | jj|j� �}| jd|� |jt� � | j t| jj|j� � | jd|j
� d S )N)r s line
r: ) r r r r; r r r rO rP r6 r< )r
r r# r r r
�test_readline_exceptionn s
z)StreamReaderTests.test_readline_exceptionc C s> t j| jd�}| jtd�� | jj|jdd�� W d Q R X d S )N)r zSeparator should ber: )� separator)r r r rS rP r � readuntil)r
r r r r
�test_readuntil_separatorz s z*StreamReaderTests.test_readuntil_separatorc C s� t j| jd�}|jd� | jj|jdd��}| jd|� | jd|j� |jd� | jj|jd��}| jd|� | jd|j� |jd� | jj|jd��}| jd|� | jd|j� d S )N)r s lineAAAs AAA)rd r: s
lineAAAxxxs xxx)r r r r; r re r r< )r
r r# r r r
�test_readuntil_multi_chunks s
z-StreamReaderTests.test_readuntil_multi_chunksc C sf t j| jd�}|jd� |jd� |jd� | jj|jd��}| jd|� | jd|j� |jd� |jd� |jd � | jj|jd��}| jd|� | jd|j� |jd� | jj|jd��}| jd|� | jd|j� |jd
� | jj|jd��}| jd
|� | jd|j� |jd � |jd� |jd� |jd� | jj|jd��}| jd |� | jd|j� d S )
N)r s QWEaas XYaa� as aaas
QWEaaXYaaar: s XYas aas Xaaas XXXs XXXaaa)r r r r; r re r r< )r
r r# r r r
� test_readuntil_multi_chunks_1� s8
z/StreamReaderTests.test_readuntil_multi_chunks_1c
C sz t j| jd�}|jd� |j� | jt j��}| jj|jd�� W d Q R X | j |j
j d� | j |j
j
� | j d|j� d S )N)r s some dataAAs AAAr: )r r r r; rI r6 �IncompleteReadErrorr re r � exception�partial� assertIsNone�expectedr< )r
r r\ r r r
�test_readuntil_eof� s
z$StreamReaderTests.test_readuntil_eofc C s� t j| jdd�}|jd� | jt jd��}| jj|jd�� W d Q R X | jd|j � |jd� | jt jd��}| jj|jd�� W d Q R X | jd|j � d S ) NrU )r rR s some dataAAz not founds AAA� Azis founds some dataAAA)
r r r r; rS �LimitOverrunErrorr re r r< )r
r r\ r r r
� test_readuntil_limit_found_sep� s
z0StreamReaderTests.test_readuntil_limit_found_sepc
C s� t j| jd�}|j| j� | jj|jd��}| jd|� | j| j|j� | j t
d�� | jj|jd�� W d Q R X | j| j|j� d S )N)r r r: zless than zerorK rL ) r r r r; r> r � readexactlyr r< rS rP )r
r r# r r r
� test_readexactly_zero_or_less� s z/StreamReaderTests.test_readexactly_zero_or_lessc s� t j� jd��dt� j� }t j�j|�� jd�}� �fdd�}� jj|� � jj|�}� j � j� j |� � j � j�j
� d S )N)r rN c s( �j � j� �j � j� �j � j� d S )N)r; r> r )r
r r r
rB � s z.StreamReaderTests.test_readexactly.<locals>.cb) r r r �lenr> rC rs rD r r r< )r
�nrE rB r# r )r
r r
�test_readexactly� s z"StreamReaderTests.test_readexactlyc C sJ t jd| jd�}|jd� | jj|jd��}| jd|� | jd|j� d S )NrU )rR r s chunkrG r: )r r r r; r rs r r< )r
r r# r r r
�test_readexactly_limit� s
z(StreamReaderTests.test_readexactly_limitc
s� t j� jd��dt� j� }t j�j|�� jd�}� �fdd�}� jj|� � jt j ��}� jj
|� W d Q R X � j |j j
� j� � j |j j|� � j t|j �d� � j d�j� d S )N)r rN c s �j � j� �j� d S )N)r; r> rI r )r
r r r
rB � s z2StreamReaderTests.test_readexactly_eof.<locals>.cbz-18 bytes read on a total of 36 expected bytesr: )r r r ru r> rC rs rD r6 rj r r rk rl rn �strr< )r
rv rE rB r\ r )r
r r
�test_readexactly_eof� s z&StreamReaderTests.test_readexactly_eofc C s^ t j| jd�}|jd� | jj|jd��}| jd|� |jt� � | j t| jj|jd�� d S )N)r s line
rN s li)
r r r r; r rs r rO rP r6 )r
r r# r r r
�test_readexactly_exception s
z,StreamReaderTests.test_readexactly_exceptionc C s@ t j| jd�}| j|j� � t� }|j|� | j|j� |� d S )N)r )r r r rm rk rP rO r )r
r �excr r r
�test_exception s
z StreamReaderTests.test_exceptionc st t j| jd�� t j� fdd��}t j� j� | jd�}t j|� | jd�}| jjt j||g| jd�� | jt |j
� d S )N)r c s � j t� � d S )N)rO rP r )r r r
�set_err s z8StreamReaderTests.test_exception_waiter.<locals>.set_err) r r r � coroutinerC r r �waitr6 rP �result)r
r~ Zt1Zt2r )r r
�test_exception_waiter s z'StreamReaderTests.test_exception_waiterc C sn t j| jd�}t j|j� | jd�}tj| j� |j� tj| j� |jt d�� tj| j� | j
|j d � d S )N)r �message) r r r rC r r r ZcancelrO � RuntimeErrorr �_waiter)r
r �tr r r
�test_exception_cancel) s z'StreamReaderTests.test_exception_cancelc s� G dd� d�}t j� fdd��}|� j�}|j� }� jjt j||�� jd��}|j� � j|d� |� j�}|j� }� jjt j||�� jd��}|j� � j|d� d S )Nc @ sB e Zd Zdd� Zejdd� �Zdd� Zdd� Zd d
� Z d d � Z
d
S )z5StreamReaderTests.test_start_server.<locals>.MyServerc S s d | _ || _d S )N)�serverr )r
r r r r
�__init__9 s z>StreamReaderTests.test_start_server.<locals>.MyServer.__init__c s s2 |j � E d H }|j|� |j� E d H |j� d S )N)r r �drainr )r
�
client_reader�
client_writerr# r r r
�
handle_client= s
zCStreamReaderTests.test_start_server.<locals>.MyServer.handle_clientc S s8 t j � }|jd� | jjtj| j|| jd��| _|j� S )N� 127.0.0.1r )�sockr )r� r ) �socket�bindr r r � start_serverr� r� � getsockname)r
r� r r r
�startD s
z;StreamReaderTests.test_start_server.<locals>.MyServer.startc S s | j j| j||�� d S )N)r � create_taskr� )r
r� r� r r r
�handle_client_callbackM s zLStreamReaderTests.test_start_server.<locals>.MyServer.handle_client_callbackc S sN t j � }|jd� |j� }|j� | jjtj| j|d |d | jd��| _ |S )N� 127.0.0.1r rK )�host�portr )r� r )
r� r� r� r r r r r� r� r� )r
r� �addrr r r
�start_callbackQ s
zDStreamReaderTests.test_start_server.<locals>.MyServer.start_callbackc S s0 | j d k r,| j j� | jj| j j� � d | _ d S )N)r� r r r � wait_closed)r
r r r
�stop\ s
z:StreamReaderTests.test_start_server.<locals>.MyServer.stopN) �__name__�
__module__� __qualname__r� r r r� r� r� r� r� r r r r
�MyServer7 s r� c 3 s@ t j| d� ji�E d H \}}|jd� |j� E d H }|j� |S )Nr s
hello world!
)r r& r r r r )r� r r! �msgback)r
r r
�clientb s
z3StreamReaderTests.test_start_server.<locals>.client)r s
hello world!
) r r r r� r rC r� r r� )r
r� r� r� r� �msgr )r
r
�test_start_server5 s +
z#StreamReaderTests.test_start_serverc s� G dd� d�}t j� fdd��}tj� �J}|� j|�}|j� � jjt j||�� jd��}|j� � j |d� W d Q R X tj� �J}|� j|�}|j
� � jjt j||�� jd��}|j� � j |d� W d Q R X d S )Nc @ sB e Zd Zdd� Zejdd� �Zdd� Zdd� Zd d
� Z d d � Z
d
S )z:StreamReaderTests.test_start_unix_server.<locals>.MyServerc S s d | _ || _|| _d S )N)r� r �path)r
r r� r r r
r� � s zCStreamReaderTests.test_start_unix_server.<locals>.MyServer.__init__c s s2 |j � E d H }|j|� |j� E d H |j� d S )N)r r r� r )r
r� r� r# r r r
r� � s
zHStreamReaderTests.test_start_unix_server.<locals>.MyServer.handle_clientc S s$ | j jtj| j| j| j d��| _d S )N)r� r )r r r �start_unix_serverr� r� r� )r
r r r
r� � s z@StreamReaderTests.test_start_unix_server.<locals>.MyServer.startc S s | j j| j||�� d S )N)r r� r� )r
r� r� r r r
r� � s zQStreamReaderTests.test_start_unix_server.<locals>.MyServer.handle_client_callbackc S s( t j| j| j| jd�}| jj|�| _d S )N)r� r )r r� r� r� r r r� )r
r� r r r
r� � s
zIStreamReaderTests.test_start_unix_server.<locals>.MyServer.start_callbackc S s0 | j d k r,| j j� | jj| j j� � d | _ d S )N)r� r r r r� )r
r r r
r� � s
z?StreamReaderTests.test_start_unix_server.<locals>.MyServer.stopN) r� r� r� r� r r r� r� r� r� r� r r r r
r� � s r� c 3 s> t j| � jd�E d H \}}|jd� |j� E d H }|j� |S )N)r s
hello world!
)r r, r r r r )r� r r! r� )r
r r
r� � s
z8StreamReaderTests.test_start_unix_server.<locals>.client)r s
hello world!
) r r r Zunix_socket_pathr r� r rC r� r r� )r
r� r� r� r� r� r )r
r
�test_start_unix_server} s $
z(StreamReaderTests.test_start_unix_serverZwin32zDon't have pipesc
s� d}t j� \}}tjd|t|�g}t|dd�}tj| jdd�}tj || jd�� | jj
| jj � fdd �|��\}}tj � } | j
| j� z@tj| � tj||h| jd
��}
| jj
|
�} | jj
| j� � W d tjd � X t j|� | jj
|jd ��} | j| d � d S )
NzHimport os, sys
fd = int(sys.argv[1])
os.write(fd, b'data')
os.close(fd)
z-c�rbr rK )r rR )r c s � S )Nr r )�protocolr r
�<lambda>� s zBStreamReaderTests.test_read_all_from_pipe_reader.<locals>.<lambda>)Zpass_fdsr s datarL )�os�pipe�sys�
executablery �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*
z0StreamReaderTests.test_read_all_from_pipe_readerc C s6 | j tjd � tj| j� tj� }| j|j| j� d S )N)�
addCleanupr r r r r r )r
r r r r
� test_streamreader_constructor� s z/StreamReaderTests.test_streamreader_constructorc C s@ | j tjd � tj| j� tj� }tj|�}| j|j| j� d S )N) r� r r r r �Mockr� r r )r
r r� r r r
�%test_streamreaderprotocol_constructor� s
z7StreamReaderTests.test_streamreaderprotocol_constructorc
s� t j� � � fdd�}tj�fdd��}tj|d�}|jd� |j� � j� }�j t
t f�� �j j
||� � W d Q R X |j� d S )Nc
sV t j � } | �@ | jd� | jd� | j� }� j|� | j� \}}|j� W d Q R X d S )N� localhostr rK )r� r )r� r� Zlistenr� ZputZacceptr )r� r� Zcltr� )�qr r
r� s
z3StreamReaderTests.test_drain_raises.<locals>.serverc 3 s> t j| |� jd�E d H \}}x |jd� |j� E d H q W d S )N)r s foo
)r r& r r r� )r� r� r r! )r
r r
r� s
z3StreamReaderTests.test_drain_raises.<locals>.client)�targetT)�queueZQueuer r � threadingZThreadZ setDaemonr� �getr6 �ConnectionResetError�BrokenPipeErrorr r �join)r
r� r� Zthreadr� r )r� r
r
�test_drain_raises� s
z#StreamReaderTests.test_drain_raisesc C s" t j| jd�}| jdt|�� d S )N)r z<StreamReader>)r r r r �repr)r
r r r r
�
test___repr__' s z StreamReaderTests.test___repr__c C s$ t j| jdd�}| jdt|�� d S )N�{ )r rR z<StreamReader l=123>)r r r r r� )r
r r r r
� test___repr__nondefault_limit+ s z/StreamReaderTests.test___repr__nondefault_limitc C s* t j| jd�}|j� | jdt|�� d S )N)r z<StreamReader eof>)r r r rI r r� )r
r r r r
�test___repr__eof/ s z"StreamReaderTests.test___repr__eofc C s, t j| jd�}|jd� | jdt|�� d S )N)r s dataz<StreamReader 4 bytes>)r r r r; r r� )r
r r r r
�test___repr__data4 s
z#StreamReaderTests.test___repr__datac C s2 t j| jd�}t� }|j|� | jdt|�� d S )N)r z <StreamReader e=RuntimeError()>)r r r r� rO r r� )r
r r| r r r
�test___repr__exception9 s
z(StreamReaderTests.test___repr__exceptionc C sb t j| jd�}t j| jd�|_| jt|�d� |jjd � | jj|j� d |_| j dt|�� d S )N)r z'<StreamReader w=<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%StreamReaderTests.test___repr__waiterc C sB t j| jd�}tj� |_tj� |j_d|jj_| jdt |�� d S )N)r z <Transport>z <StreamReader t=<Transport>>)
r r r r r� Z
_transport�__repr__r r r� )r
r r r r
�test___repr__transportJ s
z(StreamReaderTests.test___repr__transportc
C s� t jdd�}xvttjd �D ]d}| j|d��N tjtj||d��}| jt |�t |�� | j|j
|j
� | j|j |j � W d Q R X q W d S )Ns abc�
rK )�pickle_protocol)r� ) r rj �range�pickle�HIGHEST_PROTOCOL�subTest�loads�dumpsr ry rl rn )r
�e�proto�e2r r r
�#test_IncompleteReadError_pickleableQ s z5StreamReaderTests.test_IncompleteReadError_pickleablec
C sx t jdd�}xfttjd �D ]T}| j|d��> tjtj||d��}| jt |�t |�� | j|j
|j
� W d Q R X q W d S )Nr� r� rK )r� )r� ) r rq r� r� r� r� r� r� r ry �consumed)r
r� r� r� r r r
�!test_LimitOverrunError_pickleableZ s z3StreamReaderTests.test_LimitOverrunError_pickleable)Jr� r� r� r> r r r Zpatchr r$ r* �unittestZ
skipUnless�hasattrr� r- r. ZskipIfr0 r2 r4 r7 r8 r9 r= r? r@ rF rH rJ rM rQ rT rV rX rY rZ r] r_ r` ra rb rc rf rg ri ro rr rt rw rx rz r{ r} r� r� r� r� r� �platformr� r� r� r� r� r� r� r� r� r� r� r� r� �
__classcell__r r )r r
r sz
/ #
HD'
, r �__main__)�__doc__r r� r� r� r� r� r� r� r r0 � ImportErrorr r ZTestCaser r� �mainr r r r
�<module> s0
T