a

�z�g�
�@s$dZd
dl
mZ
Gdd�de�ZdS)z8Small helper class to provide a small slice of a stream.�)
�
exceptionsc@sFeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zed
d��
Z	dd
d�
Z
dS)�StreamSlicez)Provides a slice-like object for streams.cCs|
|_||_
||_dS�
N��_StreamSlice__stream�_StreamSlice__remaining_bytes�_StreamSlice__max_bytes)�self�streamZ	max_bytes�r�A/opt/gsutil/third_party/apitools/apitools/base/py/stream_slice.py�__init__s


zStreamSlice.__init__c

Csd
|j|j
|jfS)Nz0Slice of stream %s with %s/%s bytes not yet readr�
r	rrr�__str__s

�zStreamSlice.__str__c


Cs|jSr�
rrrrr�__len__#s
zStreamSlice.__len__c

Cs
t|j
�
Sr)�boolrrrrr�__nonzero__&szStreamSlice.__nonzero__c


Cs|jSrrrrrr�length+szStreamSlice.lengthNcCsf|
d
u
rt|
|j
�}n|j
}|j�|�
}|dkrP|sPt�d|j|j|j
f�
�
|j
t|�
8_
|S)aGRead at most size bytes from this slice.

        Compared to other streams, there is one case where we may
        unexpectedly raise an exception on read: if the underlying stream
        is exhausted (i.e. returns no bytes on read), and the size of this
        slice indicates we should still be able to read more bytes, we
        raise exceptions.StreamExhausted.

        Args:
          size: If provided, read no more than size bytes from the stream.

        Returns:
          The bytes read from this slice.

        Raises:
          exceptions.StreamExhausted

        Nr
z;Not enough bytes in stream; expected %d, exhausted after %d)�minrr�readr�StreamExhaustedr�len)r	�sizeZ	read_size�datarrrr0s






���
zStreamSlice.read)
N)�__name__�
__module__�__qualname__�__doc__r
rrr�propertyrrrrrrrs

rN)r�apitools.base.pyr�objectrrrrr�<module>s