a ù!f[ ã@s$dZddlmZGdd„deƒZdS)z8Small helper class to provide a small slice of a stream.é)Ú http_clientc@sFeZdZdZdd„Zdd„Zdd„Zdd „Zed d „ƒZ dd d„Z d S)Ú StreamSlicezíProvides a slice-like object for streams. :type stream: readable file-like object :param stream: the stream to be buffered :type max_bytes: integer :param max_bytes: maximum number of bytes to return in the slice cCs||_||_||_dS©N©Ú_streamÚ_remaining_bytesÚ _max_bytes)ÚselfÚstreamZ max_bytes©r ú^/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/streaming/stream_slice.pyÚ__init__szStreamSlice.__init__cCsd|j|j|jfS)Nz0Slice of stream %s with %s/%s bytes not yet readr©r r r r Ú__repr__"s ÿzStreamSlice.__repr__cCs|jSr©rrr r r Ú__len__&szStreamSlice.__len__cCs t|jƒSr)Úboolrrr r r Ú __nonzero__)szStreamSlice.__nonzero__cCs|jS)zÝMaximum number of bytes to return in the slice. .. note:: For 32-bit python2.x, len() cannot exceed a 32-bit number. :rtype: integer :returns: The max "length" of the stream. rrr r r Úlength.s zStreamSlice.lengthNcCs`|durt||jƒ}n|j}|j |¡}|dkrJ|sJt |j|j|j¡‚|jt|ƒ8_|S)aIRead bytes from the 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 :exc:`IncompleteRead`. :type size: integer or None :param size: If provided, read no more than size bytes from the stream. :rtype: bytes :returns: bytes read from this slice. :raises: :exc:`IncompleteRead` Nr)ÚminrrÚreadrÚIncompleteReadrÚlen)r ÚsizeÚ read_sizeÚdatar r r r;s  ÿzStreamSlice.read)N) Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrÚpropertyrrr r r r rs rN)rZ six.movesrÚobjectrr r r r Ús