File: //opt/gsutil/third_party/apitools/apitools/base/py/__pycache__/buffered_stream.cpython-39.pyc
a
�z�g
� @ s$ d Z ddlmZ G dd� de�ZdS )zSmall helper class to provide a small slice of a stream.
This class reads ahead to detect if we are at the end of the stream.
� )�
exceptionsc @ sV e Zd ZdZdd� Zdd� Zdd� Zedd � �Zed
d � �Z ed d
� �Z
ddd�Z dS )�BufferedStreamzABuffers a stream, reading ahead to determine if we're at the end.c C sF || _ || _d| _| j �|�| _t| j�|k | _| jt| j� | _d S )Nr )�_BufferedStream__stream�_BufferedStream__start_pos�_BufferedStream__buffer_pos�read� _BufferedStream__buffered_data�len� _BufferedStream__stream_at_end�_BufferedStream__end_pos)�self�stream�start�size� r �D/opt/gsutil/third_party/apitools/apitools/base/py/buffered_stream.py�__init__ s zBufferedStream.__init__c C s d| j | j| j| jf S )Nz>Buffered stream %s from position %s-%s with %s bytes remaining)r r r �_bytes_remaining�r r r r �__str__& s
��zBufferedStream.__str__c C s
t | j�S �N)r r r r r r �__len__+ s zBufferedStream.__len__c C s | j S r )r
r r r r �stream_exhausted. s z BufferedStream.stream_exhaustedc C s | j S r )r r r r r �stream_end_position2 s z"BufferedStream.stream_end_positionc C s t | j�| j S r )r r r r r r r r 6 s z BufferedStream._bytes_remainingNc C sn |du s|dk r0t �d|| j| j| j| jf ��d}| jrjt|| j�}| j| j| j| � }| j|7 _|S )zReads from the buffer.Nr zpIllegal read of size %s requested on BufferedStream. Wrapped stream %s is at position %s-%s, %s bytes remaining.� ) r �NotYetImplementedErrorr r r r �minr r )r r �datar r r r : s ��� �zBufferedStream.read)N) �__name__�
__module__� __qualname__�__doc__r r r �propertyr r r r r r r r r s
r N)r! �apitools.base.pyr �objectr r r r r �<module> s