a
    !f	                     @   s   d dl Z G dd de jZdS )    Nc                   @   sL   e Zd Zdd Zdd Zdd Zdd Zd	d
 Zdd Zdd Z	dd Z
dS )Test_StreamSlicec                 C   s   ddl m} |S )Nr   )StreamSlice)Zgcloud.streaming.stream_slicer   )selfr    r   c/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/streaming/test_stream_slice.py_getTargetClass   s    z Test_StreamSlice._getTargetClassc                 O   s   |   |i |S )N)r   )r   argskwr   r   r   _makeOne
   s    zTest_StreamSlice._makeOnec                 C   sv   ddl m} d}d}||}| ||}| |j|u  | |j| | |j| | t|| | |j	| d S Nr   BytesIO   CONTENT GOES HERE   )
ior   r
   
assertTrue_streamassertEqual_remaining_bytesZ
_max_byteslenlengthr   r   CONTENTMAXSIZEstreamstream_slicer   r   r   	test_ctor   s    zTest_StreamSlice.test_ctorc                 C   s6   ddl m} d}d}||}| ||}| | d S )Nr   r       )r   r   r
   ZassertFalser   r   r   r   test___nonzero___empty   s    z'Test_StreamSlice.test___nonzero___emptyc                 C   s6   ddl m} d}d}||}| ||}| | d S r   )r   r   r
   r   r   r   r   r   test___nonzero___nonempty!   s    z*Test_StreamSlice.test___nonzero___nonemptyc                 C   sl   ddl m} ddlm} d}d}||}| ||}| |j |  W d    n1 s^0    Y  d S )Nr   r   )http_clientr   r   )r   r   Z	six.movesr    r
   assertRaisesIncompleteReadread)r   r   r    r   r   r   r   r   r   r   test_read_exhausted)   s    z$Test_StreamSlice.test_read_exhaustedc                 C   sR   ddl m} d}d}||}| ||}| | |d |  | |jd d S r   r   r   r
   r   r#   r   r   r   r   r   test_read_implicit_size3   s    z(Test_StreamSlice.test_read_implicit_sizec                 C   s\   ddl m} d}d}d}||}| ||}| |||d |  | |j||  d S )Nr   r   r   r      r%   )r   r   r   r   ZSIZEr   r   r   r   r   test_read_explicit_size<   s    z(Test_StreamSlice.test_read_explicit_sizeN)__name__
__module____qualname__r   r
   r   r   r   r$   r&   r(   r   r   r   r   r      s   
	r   )Z	unittest2ZTestCaser   r   r   r   r   <module>   s   