JSrSSKJr SSKJr S/rS Sjr"SS\5rg) z!Compression support for apitools.)deque)gzipCompressStreamNc\SnSn[5n[R"SUUS9nU(aURU:aTUR U5n[ U5n UR U5 XI- nX:aSnOU(dMBURU:aMTSSS5 XdU4$!,(df  N=f)a{Compresses an input stream into a file-like buffer. This reads from the input stream until either we've stored at least length compressed bytes, or the input stream has been exhausted. This supports streams of unknown size. Args: in_stream: The input stream to read from. length: The target number of compressed bytes to buffer in the output stream. If length is none, the input stream will be compressed until it's exhausted. The actual length of the output buffer can vary from the target. If the input stream is exhaused, the output buffer may be smaller than expected. If the data is incompressible, the maximum length can be exceeded by can be calculated to be: chunksize + 5 * (floor((chunksize - 1) / 16383) + 1) + 17 This accounts for additional header data gzip adds. For the default 16MiB chunksize, this results in the max size of the output buffer being: length + 16Mib + 5142 bytes compresslevel: Optional, defaults to 2. The desired compression level. chunksize: Optional, defaults to 16MiB. The chunk size used when reading data from the input stream to write into the output buffer. Returns: A file-like output buffer of compressed bytes, the number of bytes read from the input stream, and a flag denoting if the input stream was exhausted. rFwb)modefileobj compresslevelTN)StreamingBufferrGzipFilelengthreadlenwrite) in_streamr r chunksizein_read in_exhausted out_streamcompress_streamdata data_lengths /lib/third_party/apitools/base/py/compression.pyrrsNGL "J D)%2 47FJ--6>>),Dd)K  ! !$ '  "G&# &J--6  4  ,, 4 4sAB?B B+cJ\rSrSrSrSrSrSr\S5r Sr S S jr S r g) r XzProvides a file-like object that writes to a temporary buffer. When data is read from the buffer, it is permanently removed. This is useful when there are memory constraints preventing the entire buffer from being stored in memory. c0[5UlSUlg)Nr)r_StreamingBuffer__buf_StreamingBuffer__sizeselfs r__init__StreamingBuffer.__init__asW  cUR$Nrrs r__len__StreamingBuffer.__len__gs {{r#c,[UR5$r%)boolrrs r __nonzero__StreamingBuffer.__nonzero__jsDKK  r#cUR$r%r&rs rr StreamingBuffer.lengthos{{r#cUbBU(a:URRU5 U=R[U5- slgggr%)rappendrr)r rs rrStreamingBuffer.writets8   JJ  d # KK3t9 $K!% r#NcUc URn/nUS:acUR(aRURR5nU[U5-nUR U5 US:aUR(aMRUS:a/USSUUSUSsUS'nURR U5 SR U5nU=R[U5-slU$)aRead at most size bytes from this buffer. Bytes read from this buffer are consumed and are permanently removed. Args: size: If provided, read no more than size bytes from the buffer. Otherwise, this reads the entire buffer. Returns: The bytes read from this buffer. Nrr#)rrpopleftrr0 appendleftjoin)r sizeret_listr remainderrets rrStreamingBuffer.read{s <;;DQh4::::%%'D CI D OOD !Qh4::: !8&.rl5D&98B<;N #HRL) JJ ! !) ,hhx  s3x  r#)__buf__sizer%) __name__ __module__ __qualname____firstlineno____doc__r!r'r+propertyr rr__static_attributes__r#rr r Xs4 ! %r#r )Ni) rB collectionsrapitools.base.pyr__all__robjectr rEr#rrKs6"(! :;%7-t;f;r#